io.reactivex

Interface Emitter<T>

Type Parameters:

T - the value type emitted

All Known Subinterfaces:

FlowableEmitter<T>, ObservableEmitter<T>

public interface Emitter<T>

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

Note that the onNext(T), onError(java.lang.Throwable) and 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
void	onComplete() Signal a completion.
void	onError(Throwable error) Signal a Throwable exception.
void	onNext(T value) Signal a normal value.

Method Detail

onNext

void onNext(@NonNull
            T value)

Signal a normal value.

Parameters:

value - the value to signal, not null

onError

void onError(@NonNull
             Throwable error)

Signal a Throwable exception.

Parameters:

error - the Throwable to signal, not null

onComplete

void onComplete()

Signal a completion.