Package rx.internal.util
Class BlockingUtils
- java.lang.Object
-
- rx.internal.util.BlockingUtils
-
@Experimental public final class BlockingUtils extends java.lang.Object
Utility functions relating to blocking types. Not intended to be part of the public API.
-
-
Constructor Summary
Constructors Modifier Constructor Description private
BlockingUtils()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static void
awaitForComplete(java.util.concurrent.CountDownLatch latch, Subscription subscription)
Blocks and waits for aSubscription
to complete.
-
-
-
Method Detail
-
awaitForComplete
@Experimental public static void awaitForComplete(java.util.concurrent.CountDownLatch latch, Subscription subscription)
Blocks and waits for aSubscription
to complete.- Parameters:
latch
- a CountDownLatchsubscription
- the Subscription to wait on.
-
-