public final class BlockingUtils extends Object
Modifier and Type | Method and Description |
---|---|
static void |
awaitForComplete(CountDownLatch latch,
Subscription subscription)
Blocks and waits for a
Subscription to complete. |
public static void awaitForComplete(CountDownLatch latch, Subscription subscription)
Subscription
to complete.latch
- a CountDownLatchsubscription
- the Subscription to wait on.Copyright © 2018. All rights reserved.