BlockingUtils

java.lang.Object

rx.internal.util.BlockingUtils

@Experimental public final class BlockingUtils extends 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

Modifier and Type

Method

Description

static void

awaitForComplete(CountDownLatch latch, Subscription subscription)

Blocks and waits for a Subscription to complete.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details
- BlockingUtils
  
  private BlockingUtils()
Method Details
- awaitForComplete
  
  @Experimental public static void awaitForComplete(CountDownLatch latch, Subscription subscription)
  
  Blocks and waits for a Subscription to complete.
  
  Parameters:
  
  latch - a CountDownLatch
  
  subscription - the Subscription to wait on.