rx

Interface CompletableEmitter

public interface CompletableEmitter

Abstraction over a 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.

Since:

1.3

Method Summary

Modifier and Type	Method and Description
void	onCompleted() Notifies the CompletableSubscriber that the Completable has finished sending push-based notifications.
void	onError(java.lang.Throwable t) Notifies the CompletableSubscriber that the Completable has experienced an error condition.
void	setCancellation(Cancellable c) Sets a Cancellable on this emitter; any previous Subscription or Cancellation will be unsubscribed/cancelled.
void	setSubscription(Subscription s) Sets a Subscription on this emitter; any previous Subscription or Cancellation will be unsubscribed/cancelled.

Method Detail

onCompleted

void onCompleted()

Notifies the CompletableSubscriber that the Completable has finished sending push-based notifications.

The Observable will not call this method if it calls onError(java.lang.Throwable).

onError

void onError(java.lang.Throwable t)

Notifies the CompletableSubscriber that the Completable has experienced an error condition.

If the Completable calls this method, it will not thereafter call onCompleted().

Parameters:

t - the exception encountered by the Observable

setSubscription

void setSubscription(Subscription s)

Sets a Subscription on this emitter; any previous Subscription or Cancellation will be unsubscribed/cancelled.

Parameters:

s - the subscription, null is allowed

setCancellation

void setCancellation(Cancellable c)

Sets a Cancellable on this emitter; any previous Subscription or Cancellation will be unsubscribed/cancelled.

Parameters:

c - the cancellable resource, null is allowed