io.reactivex.observable

Interface MaybeObserver<T>

Type Parameters:

T - the type of item the MaybeObserver expects to observe

All Known Implementing Classes:

DisposableMaybeObserver, MaybeSubject, ResourceMaybeObserver, TestObserver

public interface MaybeObserver<T>

Provides a mechanism for receiving push-based notifications.

After a MaybeObserver calls a Maybe's subscribe method, first the Maybe calls onSubscribe(Disposable) with a Disposable that allows cancelling the sequence at any time, then the Maybe calls only one of the MaybeObserver's onSuccess(T), onError(java.lang.Throwable) or onComplete() methods to provide notifications.

Since:

2.0

See Also:

ReactiveX documentation: Observable

Method Summary

Modifier and Type	Method and Description
void	onComplete() Called once the deferred computation completes normally.
void	onError(java.lang.Throwable e) Notifies the MaybeObserver that the Maybe has experienced an error condition.
void	onSubscribe(io.reactivex.common.Disposable d) Provides the MaybeObserver with the means of cancelling (disposing) the connection (channel) with the Maybe in both synchronous (from within onSubscribe(Disposable) itself) and asynchronous manner.
void	onSuccess(T t) Notifies the MaybeObserver with one item and that the Maybe has finished sending push-based notifications.

Method Detail

onSubscribe

void onSubscribe(@NonNull
                 io.reactivex.common.Disposable d)

Provides the MaybeObserver with the means of cancelling (disposing) the connection (channel) with the Maybe in both synchronous (from within onSubscribe(Disposable) itself) and asynchronous manner.

Parameters:

d - the Disposable instance whose Disposable.dispose() can be called anytime to cancel the connection

onSuccess

void onSuccess(@NonNull
               T t)

Notifies the MaybeObserver with one item and that the Maybe has finished sending push-based notifications.

The Maybe will not call this method if it calls onError(java.lang.Throwable).

Parameters:

t - the item emitted by the Maybe

onError

void onError(@NonNull
             java.lang.Throwable e)

Notifies the MaybeObserver that the Maybe has experienced an error condition.

If the Maybe calls this method, it will not thereafter call onSuccess(T).

Parameters:

e - the exception encountered by the Maybe

onComplete

void onComplete()

Called once the deferred computation completes normally.