Class BlockingHelper


  • public final class BlockingHelper
    extends java.lang.Object
    Utility methods for helping common blocking operations.
    • Constructor Summary

      Constructors 
      Modifier Constructor Description
      private BlockingHelper()
      Utility class.
    • Method Summary

      All Methods Static Methods Concrete Methods 
      Modifier and Type Method Description
      static void awaitForComplete​(java.util.concurrent.CountDownLatch latch, Disposable subscription)  
      static void verifyNonBlocking()
      Checks if the failOnNonBlockingScheduler plugin setting is enabled and the current thread is a Scheduler sensitive to blocking operators.
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Constructor Detail

      • BlockingHelper

        private BlockingHelper()
        Utility class.
    • Method Detail

      • awaitForComplete

        public static void awaitForComplete​(java.util.concurrent.CountDownLatch latch,
                                            Disposable subscription)
      • verifyNonBlocking

        public static void verifyNonBlocking()
        Checks if the failOnNonBlockingScheduler plugin setting is enabled and the current thread is a Scheduler sensitive to blocking operators.
        Throws:
        java.lang.IllegalStateException - if the failOnNonBlockingScheduler and the current thread is sensitive to blocking