public final class BlockingHelper extends Object
Modifier and Type | Method and 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. |
public static void awaitForComplete(CountDownLatch latch, Disposable subscription)
public static void verifyNonBlocking()
failOnNonBlockingScheduler
plugin setting is enabled and the current
thread is a Scheduler sensitive to blocking operators.IllegalStateException
- if the failOnNonBlockingScheduler
and the current thread is sensitive to blockingCopyright © 2019. All rights reserved.