Class BlockingHelper
- java.lang.Object
-
- io.reactivex.rxjava3.internal.util.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 thefailOnNonBlockingScheduler
plugin setting is enabled and the current thread is a Scheduler sensitive to blocking operators.
-
-
-
Method Detail
-
awaitForComplete
public static void awaitForComplete(java.util.concurrent.CountDownLatch latch, Disposable subscription)
-
verifyNonBlocking
public static void verifyNonBlocking()
Checks if thefailOnNonBlockingScheduler
plugin setting is enabled and the current thread is a Scheduler sensitive to blocking operators.- Throws:
java.lang.IllegalStateException
- if thefailOnNonBlockingScheduler
and the current thread is sensitive to blocking
-
-