public class RxExecutor extends Object implements RxSubscriber
| Modifier and Type | Class and Description |
|---|---|
static interface |
RxExecutor.Has
Marker interface which allows an Executor to specify its own Scheduler.
|
| Modifier and Type | Method and Description |
|---|---|
<T> Subscription |
subscribe(CompletionStage<? extends T> future,
RxListener<T> untracedListener)
Subscribes the given listener to the given Java 8 CompletableFuture.
|
<T> Subscription |
subscribe(ListenableFuture<? extends T> future,
RxListener<T> untracedListener)
Subscribes the given listener to the given Guava ListenableFuture.
|
<T> Subscription |
subscribe(Observable<? extends T> observable,
RxListener<T> untracedListener)
Subscribes the given listener to the given observable.
|
public <T> Subscription subscribe(Observable<? extends T> observable, RxListener<T> untracedListener)
RxSubscribersubscribe in interface RxSubscriberpublic <T> Subscription subscribe(CompletionStage<? extends T> future, RxListener<T> untracedListener)
RxSubscribersubscribe in interface RxSubscriberpublic <T> Subscription subscribe(ListenableFuture<? extends T> future, RxListener<T> untracedListener)
RxSubscribersubscribe in interface RxSubscriber