| io.reactivex.CompletableEmitter |
Abstraction over an RxJava CompletableObserver that allows associating
a resource with it.
All methods are safe to call from multiple threads.
Calling onComplete or onError multiple times has no effect.
| Public Methods | |||||||||||
|---|---|---|---|---|---|---|---|---|---|---|---|
| abstract boolean |
isDisposed()
Returns true if the downstream disposed the sequence.
| ||||||||||
| abstract void |
onComplete()
Signal the completion.
| ||||||||||
| abstract void |
onError(Throwable t)
Signal an exception.
| ||||||||||
| abstract void |
setCancellable(Cancellable c)
Sets a Cancellable on this emitter; any previous Disposable
or Cancellation will be disposed/cancelled.
| ||||||||||
| abstract void |
setDisposable(Disposable d)
Sets a Disposable on this emitter; any previous Disposable
or Cancellation will be disposed/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 disposed the sequence.
Signal the completion.
Signal an exception.
| t | the exception, not null |
|---|
Sets a Cancellable on this emitter; any previous Disposable or Cancellation will be disposed/cancelled.
| c | the cancellable resource, null is allowed |
|---|
Sets a Disposable on this emitter; any previous Disposable or Cancellation will be disposed/cancelled.
| d | 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 |
|---|