io.reactivex

public Interface Emitter<T>

Known Direct Subinterfaces

io.reactivex.FlowableEmitter, io.reactivex.ObservableEmitter

Known Direct Implementers

io.reactivex.internal.operators.flowable.FlowableGenerate.GeneratorSubscription, io.reactivex.internal.operators.observable.ObservableGenerate.GeneratorDisposable

Type Parameters

<T>: the value type emitted

Imports

io.reactivex.annotations.NonNull

Base interface for emitting signals in a push-fashion in various generator-like source operators (create, generate).

Note that the Emitter#onNext, Emitter#onError and Emitter#onComplete methods provided to the function via the Emitter instance should be called synchronously, never concurrently. Calling them from multiple threads is not supported and leads to an undefined behavior.

Method Summary

Modifier and Type	Method and Description
public void	onComplete() Signal a completion.
public void	onError(Throwable the Throwable to signal, not null error) Signal a Throwable exception.
public void	onNext(T the value to signal, not null value) Signal a normal value.

Method Detail

onComplete	back to summary
public void onComplete() Signal a completion.

onError	back to summary
public void onError(Throwable error) Signal a Throwable exception. Parameters error:Throwable the Throwable to signal, not null

onError

back to summary

public void onError(Throwable error)

Signal a Throwable exception.

Parameters

error:Throwable: the Throwable to signal, not null

onNext	back to summary
public void onNext(T value) Signal a normal value. Parameters value:T the value to signal, not null

onNext

back to summary

public void onNext(T value)

Signal a normal value.

Parameters

value:T: the value to signal, not null