@Experimental public final class BlockingUtils extends Object
| Modifier and Type | Method and Description |
|---|---|
static void |
awaitForComplete(CountDownLatch
Blocks and waits for a
Subscription to complete.
|
@Experimental public static void awaitForComplete(CountDownLatchlatch, Subscription subscription)
Subscription to complete.
latch - a CountDownLatch
subscription - the Subscription to wait on.