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 |
---|