Top Description Inners Constructors Methods
rx.internal.operators

public final Class OnSubscribeToObservableFuture

extends Object
Class Inheritance
Imports
java.util.concurrent.*, rx.Observable.OnSubscribe, .Subscriber, rx.exceptions.Exceptions, rx.functions.Action0, rx.internal.producers.SingleProducer, rx.subscriptions.Subscriptions
Converts a Future into an Observable.

You can convert any object that supports the Future interface into an Observable that emits the return value of the get method of that object, by using this operator.

This is blocking so the Subscription returned when calling Observable.unsafeSubscribe(Observer) does nothing.

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv static class
OnSubscribeToObservableFuture.ToObservableFuture<T>

Constructor Summary

AccessConstructor and Description
private
OnSubscribeToObservableFuture()

Method Summary

Modifier and TypeMethod and Description
public static <T> Observable.OnSubscribe<T>
toObservableFuture(final Future<? extends T> that)

public static <T> Observable.OnSubscribe<T>
toObservableFuture(final Future<? extends T> that, long time, TimeUnit unit)

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Constructor Detail

OnSubscribeToObservableFutureback to summary
private OnSubscribeToObservableFuture()

Method Detail

toObservableFutureback to summary
public static <T> Observable.OnSubscribe<T> toObservableFuture(final Future<? extends T> that)
toObservableFutureback to summary
public static <T> Observable.OnSubscribe<T> toObservableFuture(final Future<? extends T> that, long time, TimeUnit unit)
rx.internal.operators back to summary

pack-priv Class OnSubscribeToObservableFuture.ToObservableFuture<T>

extends Object
implements Observable.OnSubscribe<T>
Class Inheritance
  • java.lang.Object
  • rx.internal.operators.OnSubscribeToObservableFuture.ToObservableFuture
All Implemented Interfaces
rx.Observable.OnSubscribe, rx.functions.Action1, rx.functions.Action, rx.functions.Function

Field Summary

Modifier and TypeField and Description
pack-priv final Future<? extends T>
that

private final long
time

private final TimeUnit
unit

Constructor Summary

AccessConstructor and Description
public
ToObservableFuture(Future<? extends T> that)

public
ToObservableFuture(Future<? extends T> that, long time, TimeUnit unit)

Method Summary

Modifier and TypeMethod and Description
public void
call(Subscriber<? super T> subscriber)

Implements rx.functions.Action1.call.

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

thatback to summary
pack-priv final Future<? extends T> that
timeback to summary
private final long time
unitback to summary
private final TimeUnit unit

Constructor Detail

ToObservableFutureback to summary
public ToObservableFuture(Future<? extends T> that)
ToObservableFutureback to summary
public ToObservableFuture(Future<? extends T> that, long time, TimeUnit unit)

Method Detail

callback to summary
public void call(Subscriber<? super T> subscriber)

Implements rx.functions.Action1.call.

Annotations
@Override