Top Description Constructors Methods
rx.internal.util

public final Class BlockingUtils

extends Object
Class Inheritance
Imports
rx.Subscription, java.util.concurrent.CountDownLatch
Utility functions relating to blocking types.

Not intended to be part of the public API.

Since
1.3

Constructor Summary

AccessConstructor and Description
private
BlockingUtils()

Method Summary

Modifier and TypeMethod and Description
public static void
awaitForComplete(CountDownLatch
a CountDownLatch
latch, Subscription
the Subscription to wait on.
subscription)

Blocks and waits for a Subscription to complete.

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Constructor Detail

BlockingUtilsback to summary
private BlockingUtils()

Method Detail

awaitForCompleteback to summary
public static void awaitForComplete(CountDownLatch latch, Subscription subscription)

Blocks and waits for a Subscription to complete.

Parameters
latch:CountDownLatch

a CountDownLatch

subscription:Subscription

the Subscription to wait on.