Class BlockingHelper
java.lang.Object
io.reactivex.rxjava3.internal.util.BlockingHelper
Utility methods for helping common blocking operations.
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionstatic void
awaitForComplete
(CountDownLatch latch, Disposable subscription) static void
Checks if thefailOnNonBlockingScheduler
plugin setting is enabled and the current thread is a Scheduler sensitive to blocking operators.
-
Constructor Details
-
BlockingHelper
private BlockingHelper()Utility class.
-
-
Method Details
-
awaitForComplete
-
verifyNonBlocking
public static void verifyNonBlocking()Checks if thefailOnNonBlockingScheduler
plugin setting is enabled and the current thread is a Scheduler sensitive to blocking operators.- Throws:
IllegalStateException
- if thefailOnNonBlockingScheduler
and the current thread is sensitive to blocking
-