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)
andonComplete()
methods provided to the function via theEmitter
instance should be called synchronously, never concurrently. Calling them from multiple threads is not supported and leads to an undefined behavior.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
onComplete()
Signal a completion.void
onError(@NonNull java.lang.Throwable error)
Signal aThrowable
exception.void
onNext(@NonNull T value)
Signal a normal value.
-
-
-
Method Detail
-
onNext
void onNext(@NonNull @NonNull T value)
Signal a normal value.- Parameters:
value
- the value to signal, notnull
-
onError
void onError(@NonNull @NonNull java.lang.Throwable error)
Signal aThrowable
exception.- Parameters:
error
- theThrowable
to signal, notnull
-
onComplete
void onComplete()
Signal a completion.
-
-