com.diffplug.common.rx

Interface RxSubscriber

All Known Implementing Classes:

GuardedExecutor, RxExecutor

public interface RxSubscriber

An object which can subscribe observables to RxListener listeners.

Method Summary

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

Method Detail

subscribe

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

Subscribes the given listener to the given observable.

subscribe

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

Subscribes the given listener to the given Guava ListenableFuture.

subscribe

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

Subscribes the given listener to the given Java 8 CompletableFuture.

subscribe

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

subscribe

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

subscribe

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

subscribe

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

subscribe

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

subscribeDisposable

<T> Disposable subscribeDisposable(Observable<? extends T> observable,
                                   RxListener<T> listener)

Subscribes the given listener to the given observable.

subscribeDisposable

<T> Disposable subscribeDisposable(ListenableFuture<? extends T> future,
                                   RxListener<T> listener)

Subscribes the given listener to the given Guava ListenableFuture.

subscribeDisposable

<T> Disposable subscribeDisposable(CompletionStage<? extends T> future,
                                   RxListener<T> listener)

Subscribes the given listener to the given Java 8 CompletableFuture.

subscribeDisposable

default <T> Disposable subscribeDisposable(Observable<? extends T> observable,
                                           Consumer<T> listener)

subscribeDisposable

default <T> Disposable subscribeDisposable(IObservable<? extends T> observable,
                                           RxListener<T> listener)

subscribeDisposable

default <T> Disposable subscribeDisposable(IObservable<? extends T> observable,
                                           Consumer<T> listener)

subscribeDisposable

default <T> Disposable subscribeDisposable(ListenableFuture<? extends T> future,
                                           Consumer<T> listener)

subscribeDisposable

default <T> Disposable subscribeDisposable(CompletionStage<? extends T> future,
                                           Consumer<T> listener)