Uses of Interface
io.reactivex.rxjava3.core.ObservableEmitter

Packages that use ObservableEmitter

Package	Description
io.reactivex.rxjava3.core	Base reactive classes: Flowable, Observable, Single, Maybe and Completable; base reactive consumers; other common base interfaces.
io.reactivex.rxjava3.internal.operators.observable

Uses of ObservableEmitter in io.reactivex.rxjava3.core

Methods in io.reactivex.rxjava3.core that return ObservableEmitter

Modifier and Type	Method	Description
@NonNull ObservableEmitter<T>	ObservableEmitter.serialize()	Ensures that calls to onNext, onError and onComplete are properly serialized.

Methods in io.reactivex.rxjava3.core with parameters of type ObservableEmitter

Modifier and Type	Method	Description
void	ObservableOnSubscribe.subscribe(@NonNull ObservableEmitter<@NonNull T> emitter)	Called for each Observer that subscribes.

Uses of ObservableEmitter in io.reactivex.rxjava3.internal.operators.observable

Classes in io.reactivex.rxjava3.internal.operators.observable that implement ObservableEmitter

Modifier and Type	Class	Description
(package private) static class	ObservableCreate.CreateEmitter<T>
(package private) static class	ObservableCreate.SerializedEmitter<T>	Serializes calls to onNext, onError and onComplete.

Fields in io.reactivex.rxjava3.internal.operators.observable declared as ObservableEmitter

Modifier and Type	Field	Description
(package private) ObservableEmitter<T>	ObservableCreate.SerializedEmitter.emitter

Methods in io.reactivex.rxjava3.internal.operators.observable that return ObservableEmitter

Modifier and Type	Method	Description
ObservableEmitter<T>	ObservableCreate.CreateEmitter.serialize()
ObservableEmitter<T>	ObservableCreate.SerializedEmitter.serialize()

Constructors in io.reactivex.rxjava3.internal.operators.observable with parameters of type ObservableEmitter

Constructor	Description
SerializedEmitter(ObservableEmitter<T> emitter)