Class OnSubscribeToObservableFuture

java.lang.Object
rx.internal.operators.OnSubscribeToObservableFuture

public final class OnSubscribeToObservableFuture extends Object
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.

  • Constructor Details

    • OnSubscribeToObservableFuture

      private OnSubscribeToObservableFuture()
  • Method Details