| io.reactivex.MaybeObserver<T> |
Known Indirect Subclasses
|
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(Throwable) or
onComplete() methods to provide notifications.
| Public Methods | |||||||||||
|---|---|---|---|---|---|---|---|---|---|---|---|
| abstract void |
onComplete()
Called once the deferred computation completes normally.
| ||||||||||
| abstract void |
onError(Throwable e)
Notifies the MaybeObserver that the
Maybe has experienced an error condition. | ||||||||||
| abstract void |
onSubscribe(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. | ||||||||||
| abstract void |
onSuccess(T t)
Notifies the MaybeObserver with one item and that the
Maybe has finished sending
push-based notifications. | ||||||||||
Called once the deferred computation completes normally.
Notifies the MaybeObserver that the Maybe has experienced an error condition.
If the Maybe calls this method, it will not thereafter call onSuccess(T).
| e | the exception encountered by the Maybe |
|---|
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.
| d | the Disposable instance whose dispose() can
be called anytime to cancel the connection
|
|---|
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(Throwable).
| t | the item emitted by the Maybe |
|---|