Class BlockingHelper

java.lang.Object
io.reactivex.rxjava3.internal.util.BlockingHelper

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

    • BlockingHelper

      private BlockingHelper()
      Utility class.
  • Method Details

    • awaitForComplete

      public static void awaitForComplete(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:
      IllegalStateException - if the failOnNonBlockingScheduler and the current thread is sensitive to blocking