io.reactivex.internal.util

public final Class BlockingHelper

Class Inheritance

extends Object

Imports

Utility methods for helping common blocking operations.

Constructor Summary

Access	Constructor and Description
private	BlockingHelper() Utility class.

Modifier and Type	Method and Description
public static void	awaitForComplete(CountDownLatch latch, Disposable subscription)
public static void	verifyNonBlocking() Checks if the `failOnNonBlockingScheduler` plugin setting is enabled and the current thread is a Scheduler sensitive to blocking operators.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

BlockingHelper	back to summary
private BlockingHelper() Utility class.

awaitForComplete	back to summary
public static void awaitForComplete(CountDownLatch latch, Disposable subscription)

verifyNonBlocking back to summary

verifyNonBlocking	back to summary
public static void verifyNonBlocking() Checks if the `failOnNonBlockingScheduler` plugin setting is enabled and the current thread is a Scheduler sensitive to blocking operators. Exceptions IllegalStateException: if the `failOnNonBlockingScheduler` and the current thread is sensitive to blocking

public static void verifyNonBlocking()

Checks if the failOnNonBlockingScheduler plugin setting is enabled and the current thread is a Scheduler sensitive to blocking operators.

Exceptions

IllegalStateException:: if the failOnNonBlockingScheduler and the current thread is sensitive to blocking