CompletableSubscriber that gets either an onCompleted or onError
signal and allows registering an cancellation/unsubscription callback.
All methods are thread-safe; calling onCompleted or onError twice or one after the other has no effect.
| Modifier and Type | Method and Description |
|---|---|
| public void | onCompleted()
Notifies the CompletableSubscriber that the |
| public void | onError(Throwable
the exception encountered by the Observable t)Notifies the CompletableSubscriber that the |
| public void | setCancellation(Cancellable
the cancellable resource, null is allowed c)Sets a Cancellable on this emitter; any previous Subscription or Cancellation will be unsubscribed/cancelled. |
| public void | setSubscription(Subscription
the subscription, null is allowed s)Sets a Subscription on this emitter; any previous Subscription or Cancellation will be unsubscribed/cancelled. |
| onCompleted | back to summary |
|---|---|
| public void onCompleted() Notifies the CompletableSubscriber that the
The | |
| onError | back to summary |
|---|---|
| public void onError(Throwable t) Notifies the CompletableSubscriber that the
If the
| |
| setCancellation | back to summary |
|---|---|
| public void setCancellation(Cancellable c) Sets a Cancellable on this emitter; any previous Subscription or Cancellation will be unsubscribed/cancelled.
| |
| setSubscription | back to summary |
|---|---|
| public void setSubscription(Subscription s) Sets a Subscription on this emitter; any previous Subscription or Cancellation will be unsubscribed/cancelled.
| |