com.diffplug.common.rx

Class RxListener<T>

java.lang.Object

com.diffplug.common.rx.RxListener<T>

All Implemented Interfaces:

FutureCallback<T>, Observer<T>

public final class RxListener<T>
extends Object
implements Observer<T>, FutureCallback<T>

Method Summary

Modifier and Type	Method and Description
boolean	isLogging() Returns true iff the given Rx is a logging Rx.
void	onComplete()
void	onError(Throwable e)
void	onErrorDontLog(Throwable e)
void	onFailure(Throwable e)
void	onNext(T t)
void	onSubscribe(Disposable d)
void	onSuccess(T result)

Methods inherited from class java.lang.Object

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

Method Detail

onSubscribe

public void onSubscribe(Disposable d)

Specified by:

onSubscribe in interface Observer<T>

onNext

public final void onNext(@Nullable
                         T t)

Specified by:

onNext in interface Observer<T>

onComplete

public void onComplete()

Specified by:

onComplete in interface Observer<T>

onError

public final void onError(Throwable e)

Specified by:

onError in interface Observer<T>

onSuccess

public final void onSuccess(@Nullable
                            T result)

Specified by:

onSuccess in interface FutureCallback<T>

onFailure

public final void onFailure(Throwable e)

Specified by:

onFailure in interface FutureCallback<T>

onErrorDontLog

public void onErrorDontLog(Throwable e)

isLogging

public boolean isLogging()

Returns true iff the given Rx is a logging Rx.