Uses of Interface
io.reactivex.rxjava3.core.FlowableEmitter
-
Packages that use FlowableEmitter 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.flowable -
-
Uses of FlowableEmitter in io.reactivex.rxjava3.core
Methods in io.reactivex.rxjava3.core that return FlowableEmitter Modifier and Type Method Description @NonNull FlowableEmitter<T>
FlowableEmitter. serialize()
Ensures that calls toonNext
,onError
andonComplete
are properly serialized.Methods in io.reactivex.rxjava3.core with parameters of type FlowableEmitter Modifier and Type Method Description void
FlowableOnSubscribe. subscribe(@NonNull FlowableEmitter<@NonNull T> emitter)
Called for eachSubscriber
that subscribes. -
Uses of FlowableEmitter in io.reactivex.rxjava3.internal.operators.flowable
Classes in io.reactivex.rxjava3.internal.operators.flowable that implement FlowableEmitter Modifier and Type Class Description (package private) static class
FlowableCreate.BaseEmitter<T>
(package private) static class
FlowableCreate.BufferAsyncEmitter<T>
(package private) static class
FlowableCreate.DropAsyncEmitter<T>
(package private) static class
FlowableCreate.ErrorAsyncEmitter<T>
(package private) static class
FlowableCreate.LatestAsyncEmitter<T>
(package private) static class
FlowableCreate.MissingEmitter<T>
(package private) static class
FlowableCreate.NoOverflowBaseAsyncEmitter<T>
(package private) static class
FlowableCreate.SerializedEmitter<T>
Serializes calls to onNext, onError and onComplete.Methods in io.reactivex.rxjava3.internal.operators.flowable that return FlowableEmitter Modifier and Type Method Description FlowableEmitter<T>
FlowableCreate.BaseEmitter. serialize()
FlowableEmitter<T>
FlowableCreate.SerializedEmitter. serialize()
-