com.diffplug.common.rx

Class Rx.RxExecutor

java.lang.Object

com.diffplug.common.rx.Rx.RxExecutor

All Implemented Interfaces:

RxSubscriber

Enclosing class:

Rx<T>

public static class Rx.RxExecutor
extends Object
implements RxSubscriber

This class holds an instance of Executor (for ListenableFuture) and Scheduler (for Observable). It has methods which match the signatures of Rx's static methods, which allows users to

Method Summary

Modifier and Type	Method and Description
<T> Subscription	subscribe(CompletionStage<? extends T> future, Rx<T> untracedListener) Subscribes the given listener to the given Java 8 CompletableFuture.
<T> Subscription	subscribe(ListenableFuture<? extends T> future, Rx<T> untracedListener) Subscribes the given listener to the given Guava ListenableFuture.
<T> Subscription	subscribe(Observable<? extends T> observable, Rx<T> untracedListener) Subscribes the given listener to the given observable.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.diffplug.common.rx.RxSubscriber

subscribe, subscribe, subscribe, subscribe, subscribe

Method Detail

subscribe

public <T> Subscription subscribe(Observable<? extends T> observable,
                                  Rx<T> untracedListener)

Description copied from interface: RxSubscriber

Subscribes the given listener to the given observable.

Specified by:

subscribe in interface RxSubscriber

subscribe

public <T> Subscription subscribe(CompletionStage<? extends T> future,
                                  Rx<T> untracedListener)

Description copied from interface: RxSubscriber

Subscribes the given listener to the given Java 8 CompletableFuture.

Specified by:

subscribe in interface RxSubscriber

subscribe

public <T> Subscription subscribe(ListenableFuture<? extends T> future,
                                  Rx<T> untracedListener)

Description copied from interface: RxSubscriber

Subscribes the given listener to the given Guava ListenableFuture.

Specified by:

subscribe in interface RxSubscriber