Uses of Class
io.reactivex.rxjava3.processors.FlowableProcessor
-
Packages that use FlowableProcessor Package Description io.reactivex.rxjava3.internal.operators.flowable io.reactivex.rxjava3.internal.schedulers io.reactivex.rxjava3.processors Classes representing so-called hot backpressure-aware sources, aka processors, that implement theFlowableProcessor
class, the Reactive StreamsProcessor
interface to allow forms of multicasting events to one or more subscribers as well as consuming another Reactive StreamsPublisher
. -
-
Uses of FlowableProcessor in io.reactivex.rxjava3.internal.operators.flowable
Fields in io.reactivex.rxjava3.internal.operators.flowable declared as FlowableProcessor Modifier and Type Field Description protected FlowableProcessor<U>
FlowableRepeatWhen.WhenSourceSubscriber. processor
(package private) FlowableProcessor<T>
FlowableWindowSubscribeIntercept. window
Constructors in io.reactivex.rxjava3.internal.operators.flowable with parameters of type FlowableProcessor Constructor Description FlowableWindowSubscribeIntercept(FlowableProcessor<T> source)
RepeatWhenSubscriber(org.reactivestreams.Subscriber<? super T> actual, FlowableProcessor<java.lang.Object> processor, org.reactivestreams.Subscription receiver)
RetryWhenSubscriber(org.reactivestreams.Subscriber<? super T> actual, FlowableProcessor<java.lang.Throwable> processor, org.reactivestreams.Subscription receiver)
WhenSourceSubscriber(org.reactivestreams.Subscriber<? super T> actual, FlowableProcessor<U> processor, org.reactivestreams.Subscription receiver)
-
Uses of FlowableProcessor in io.reactivex.rxjava3.internal.schedulers
Fields in io.reactivex.rxjava3.internal.schedulers declared as FlowableProcessor Modifier and Type Field Description private FlowableProcessor<SchedulerWhen.ScheduledAction>
SchedulerWhen.QueueWorker. actionProcessor
private FlowableProcessor<Flowable<Completable>>
SchedulerWhen. workerProcessor
Constructors in io.reactivex.rxjava3.internal.schedulers with parameters of type FlowableProcessor Constructor Description QueueWorker(FlowableProcessor<SchedulerWhen.ScheduledAction> actionProcessor, Scheduler.Worker actualWorker)
-
Uses of FlowableProcessor in io.reactivex.rxjava3.processors
Subclasses of FlowableProcessor in io.reactivex.rxjava3.processors Modifier and Type Class Description class
AsyncProcessor<T>
Processor that emits the very last value followed by a completion event or the received error toSubscriber
s.class
BehaviorProcessor<T>
Processor that emits the most recent item it has observed and all subsequent observed items to each subscribedSubscriber
.class
MulticastProcessor<T>
AFlowableProcessor
implementation that coordinates downstream requests through a front-buffer and stable-prefetching, optionally canceling the upstream if all subscribers have cancelled.class
PublishProcessor<T>
Processor that multicasts all subsequently observed items to its currentSubscriber
s.class
ReplayProcessor<T>
Replays events to Subscribers.(package private) class
SerializedProcessor<T>
Serializes calls to the Subscriber methods.class
UnicastProcessor<T>
AFlowableProcessor
variant that queues up events until a singleSubscriber
subscribes to it, replays those events to it until theSubscriber
catches up and then switches to relaying events live to this singleSubscriber
until thisUnicastProcessor
terminates or theSubscriber
cancels its subscription.Fields in io.reactivex.rxjava3.processors declared as FlowableProcessor Modifier and Type Field Description (package private) FlowableProcessor<T>
SerializedProcessor. actual
The actual subscriber to serialize Subscriber calls to.Methods in io.reactivex.rxjava3.processors that return FlowableProcessor Modifier and Type Method Description @NonNull FlowableProcessor<T>
FlowableProcessor. toSerialized()
Wraps this FlowableProcessor and serializes the calls to the onSubscribe, onNext, onError and onComplete methods, making them thread-safe.Constructors in io.reactivex.rxjava3.processors with parameters of type FlowableProcessor Constructor Description SerializedProcessor(FlowableProcessor<T> actual)
Constructor that wraps an actual subject.
-