Package rx.internal.operators

Class BlockingOperatorNext

java.lang.Object

rx.internal.operators.BlockingOperatorNext

public final class BlockingOperatorNext
extends Object

Returns an Iterable that blocks until the Observable emits another item, then returns that item.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static final class	BlockingOperatorNext.NextIterator<T>
(package private) static final class	BlockingOperatorNext.NextObserver<T>

Constructor Summary

Constructors

Modifier	Constructor	Description
private	BlockingOperatorNext()

Method Summary

Modifier and Type	Method	Description
static <T> Iterable<T>	next(Observable<? extends T> items)	Returns an Iterable that blocks until the Observable emits another item, then returns that item.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

BlockingOperatorNext

private BlockingOperatorNext()

Method Details

next

public static <T> Iterable<T> next(Observable<? extends T> items)

Returns an Iterable that blocks until the Observable emits another item, then returns that item.

Type Parameters:

T - the value type

Parameters:

items - the Observable to observe

Returns:

an Iterable that behaves like a blocking version of items