rx.internal.operators

public final Class BlockingOperatorToFuture

Class Inheritance

extends Object

java.lang.Object
rx.internal.operators.BlockingOperatorToFuture

Imports

java.util.concurrent.*, java.util.concurrent.atomic.AtomicReference, rx.*

Returns a Future representing the single value emitted by an Observable.

The toFuture operation throws an exception if the Observable emits more than one item. If the Observable may emit more than item, use toList().toFuture().

Constructor Summary

Access	Constructor and Description
private	BlockingOperatorToFuture()

Method Summary

Modifier and Type	Method and Description
public static < the type of source. T> Future<T>	Returns: the Future to retrieve a single elements from an Observable toFuture(Observable<? extends T> an observable sequence to get a Future for. that) Returns a Future that expects a single item from the observable.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Constructor Detail

BlockingOperatorToFuture	back to summary
private BlockingOperatorToFuture()

Method Detail

toFuture	back to summary
public static <T> Future<T> toFuture(Observable<? extends T> that) Returns a Future that expects a single item from the observable. Parameters <T> the type of source. that:Observable<? extends T> an observable sequence to get a Future for. Returns:Future<T> the Future to retrieve a single elements from an Observable

toFuture

back to summary

public static <T> Future<T> toFuture(Observable<? extends T> that)

Returns a Future that expects a single item from the observable.

Parameters

<T>: the type of source.
that:Observable<? extends T>: an observable sequence to get a Future for.

Returns:Future<T>

the Future to retrieve a single elements from an Observable