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
andCompletable
; 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 toonNext
,onError
andonComplete
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 eachObserver
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)
-