public final 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 |
|---|---|
Executor |
executor() |
Scheduler |
scheduler() |
<T> void |
subscribe(CompletionStage<? extends T> future,
RxListener<T> untracedListener)
Subscribes the given listener to the given Java 8 CompletableFuture.
|
<T> void |
subscribe(ListenableFuture<? extends T> future,
RxListener<T> untracedListener)
Subscribes the given listener to the given Guava ListenableFuture.
|
<T> void |
subscribe(Observable<? extends T> observable,
RxListener<T> untracedListener)
Subscribes the given listener to the given observable.
|
<T> Disposable |
subscribeDisposable(CompletionStage<? extends T> future,
RxListener<T> untracedListener)
Subscribes the given listener to the given Java 8 CompletableFuture.
|
<T> Disposable |
subscribeDisposable(ListenableFuture<? extends T> future,
RxListener<T> untracedListener)
Subscribes the given listener to the given Guava ListenableFuture.
|
<T> Disposable |
subscribeDisposable(Observable<? extends T> observable,
RxListener<T> untracedListener)
Subscribes the given listener to the given observable.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitsubscribe, subscribe, subscribe, subscribe, subscribe, subscribeDisposable, subscribeDisposable, subscribeDisposable, subscribeDisposable, subscribeDisposablepublic Executor executor()
public Scheduler scheduler()
public <T> void subscribe(Observable<? extends T> observable, RxListener<T> untracedListener)
RxSubscribersubscribe in interface RxSubscriberpublic <T> void subscribe(ListenableFuture<? extends T> future, RxListener<T> untracedListener)
RxSubscribersubscribe in interface RxSubscriberpublic <T> void subscribe(CompletionStage<? extends T> future, RxListener<T> untracedListener)
RxSubscribersubscribe in interface RxSubscriberpublic <T> Disposable subscribeDisposable(Observable<? extends T> observable, RxListener<T> untracedListener)
RxSubscribersubscribeDisposable in interface RxSubscriberpublic <T> Disposable subscribeDisposable(ListenableFuture<? extends T> future, RxListener<T> untracedListener)
RxSubscribersubscribeDisposable in interface RxSubscriberpublic <T> Disposable subscribeDisposable(CompletionStage<? extends T> future, RxListener<T> untracedListener)
RxSubscribersubscribeDisposable in interface RxSubscriber