Package io.reactivex.rxjava3.core
Interface Emitter<T>
- Type Parameters:
T
- the value type emitted
- All Known Subinterfaces:
FlowableEmitter<T>
,ObservableEmitter<T>
- All Known Implementing Classes:
FlowableCreate.BaseEmitter
,FlowableCreate.BufferAsyncEmitter
,FlowableCreate.DropAsyncEmitter
,FlowableCreate.ErrorAsyncEmitter
,FlowableCreate.LatestAsyncEmitter
,FlowableCreate.MissingEmitter
,FlowableCreate.NoOverflowBaseAsyncEmitter
,FlowableCreate.SerializedEmitter
,FlowableGenerate.GeneratorSubscription
,ObservableCreate.CreateEmitter
,ObservableCreate.SerializedEmitter
,ObservableGenerate.GeneratorDisposable
public interface Emitter<@NonNull 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
-
Method Details
-
onNext
Signal a normal value.- Parameters:
value
- the value to signal, notnull
-
onError
Signal aThrowable
exception.- Parameters:
error
- theThrowable
to signal, notnull
-
onComplete
void onComplete()Signal a completion.
-