com.diffplug.common.rx

Interface RxSubscriber

All Known Implementing Classes:

RxExecutor

public interface RxSubscriber

An object which can subscribe observables to RxListener listeners.

Method Summary

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

Method Detail

subscribe

<T> Subscription subscribe(Observable<? extends T> observable,
                           RxListener<T> listener)

Subscribes the given listener to the given observable.

subscribe

<T> Subscription subscribe(ListenableFuture<? extends T> future,
                           RxListener<T> listener)

Subscribes the given listener to the given Guava ListenableFuture.

subscribe

<T> Subscription subscribe(CompletionStage<? extends T> future,
                           RxListener<T> listener)

Subscribes the given listener to the given Java 8 CompletableFuture.

subscribe

default <T> Subscription subscribe(Observable<? extends T> observable,
                                   Consumer<T> listener)

subscribe

default <T> Subscription subscribe(IObservable<? extends T> observable,
                                   RxListener<T> listener)

subscribe

default <T> Subscription subscribe(IObservable<? extends T> observable,
                                   Consumer<T> listener)

subscribe

default <T> Subscription subscribe(ListenableFuture<? extends T> future,
                                   Consumer<T> listener)

subscribe

default <T> Subscription subscribe(CompletionStage<? extends T> future,
                                   Consumer<T> listener)