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 Summary

Constructors

Modifier	Constructor	Description
private	BlockingHelper()	Utility class.

Method Summary

Modifier and Type	Method	Description
static void	awaitForComplete(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 Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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