io.reactivex.SingleEmitter<T> |
Abstraction over an RxJava SingleObserver
that allows associating
a resource with it.
All methods are safe to call from multiple threads.
Calling onSuccess or onError multiple times has no effect.
Public Methods | |||||||||||
---|---|---|---|---|---|---|---|---|---|---|---|
abstract boolean |
isDisposed()
Returns true if the downstream cancelled the sequence.
| ||||||||||
abstract void |
onError(Throwable t)
Signal an exception.
| ||||||||||
abstract void |
onSuccess(T t)
Signal a success value.
| ||||||||||
abstract void |
setCancellable(Cancellable c)
Sets a Cancellable on this emitter; any previous Disposable
or Cancellation will be unsubscribed/cancelled.
| ||||||||||
abstract void |
setDisposable(Disposable s)
Sets a Disposable on this emitter; any previous Disposable
or Cancellation will be unsubscribed/cancelled.
| ||||||||||
abstract boolean |
tryOnError(Throwable t)
Attempts to emit the specified
Throwable error if the downstream
hasn't cancelled the sequence or is otherwise terminated, returning false
if the emission is not allowed to happen due to lifecycle restrictions. |
Returns true if the downstream cancelled the sequence.
Signal an exception.
t | the exception, not null |
---|
Signal a success value.
t | the value, not null |
---|
Sets a Cancellable on this emitter; any previous Disposable or Cancellation will be unsubscribed/cancelled.
c | the cancellable resource, null is allowed |
---|
Sets a Disposable on this emitter; any previous Disposable or Cancellation will be unsubscribed/cancelled.
s | the disposable, null is allowed |
---|
Attempts to emit the specified Throwable
error if the downstream
hasn't cancelled the sequence or is otherwise terminated, returning false
if the emission is not allowed to happen due to lifecycle restrictions.
Unlike onError(Throwable)
, the RxJavaPlugins.onError
is not called
if the error could not be delivered.
t | the throwable error to signal if possible |
---|