io.reactivex

Interface ObservableEmitter<T>

Type Parameters:

T - the value type to emit

All Superinterfaces:

Emitter<T>

public interface ObservableEmitter<T>
extends Emitter<T>

Abstraction over an RxJava Observer that allows associating a resource with it.

The onNext, onError and onComplete methods should be called in a sequential manner, just like the Observer's methods. Use serialize() if you want to ensure this. The other methods are thread-safe.

Method Summary

Methods

Modifier and Type	Method and Description
boolean	isDisposed() Returns true if the downstream disposed the sequence.
ObservableEmitter<T>	serialize() Ensures that calls to onNext, onError and onComplete are properly serialized.
void	setCancellable(Cancellable c) Sets a Cancellable on this emitter; any previous Disposable or Cancellation will be unsubscribed/cancelled.
void	setDisposable(Disposable d) Sets a Disposable on this emitter; any previous Disposable or Cancellation will be unsubscribed/cancelled.

Methods inherited from interface io.reactivex.Emitter

onComplete, onError, onNext

Method Detail

setDisposable

void setDisposable(Disposable d)

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

Parameters:

d - the disposable, null is allowed

setCancellable

void setCancellable(Cancellable c)

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

Parameters:

c - the cancellable resource, null is allowed

isDisposed

boolean isDisposed()

Returns true if the downstream disposed the sequence.

Returns:

true if the downstream disposed the sequence

serialize

ObservableEmitter<T> serialize()

Ensures that calls to onNext, onError and onComplete are properly serialized.

Returns:

the serialized ObservableEmitter