Uses of Class
io.reactivex.rxjava3.processors.FlowableProcessor
Packages that use FlowableProcessor
Package
Description
Classes representing so-called hot backpressure-aware sources, aka processors,
that implement the
FlowableProcessor
class,
the Reactive Streams Processor
interface
to allow forms of multicasting events to one or more subscribers as well as consuming another
Reactive Streams Publisher
.-
Uses of FlowableProcessor in io.reactivex.rxjava3.internal.operators.flowable
Fields in io.reactivex.rxjava3.internal.operators.flowable declared as FlowableProcessorModifier and TypeFieldDescriptionprotected final FlowableProcessor
<U> FlowableRepeatWhen.WhenSourceSubscriber.processor
(package private) final FlowableProcessor
<T> FlowableWindowSubscribeIntercept.window
Constructors in io.reactivex.rxjava3.internal.operators.flowable with parameters of type FlowableProcessorModifierConstructorDescription(package private)
(package private)
RepeatWhenSubscriber
(org.reactivestreams.Subscriber<? super T> actual, FlowableProcessor<Object> processor, org.reactivestreams.Subscription receiver) (package private)
RetryWhenSubscriber
(org.reactivestreams.Subscriber<? super T> actual, FlowableProcessor<Throwable> processor, org.reactivestreams.Subscription receiver) (package private)
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 FlowableProcessorModifier and TypeFieldDescriptionprivate final FlowableProcessor
<SchedulerWhen.ScheduledAction> SchedulerWhen.QueueWorker.actionProcessor
private final FlowableProcessor
<Flowable<Completable>> SchedulerWhen.workerProcessor
Constructors in io.reactivex.rxjava3.internal.schedulers with parameters of type FlowableProcessorModifierConstructorDescription(package private)
QueueWorker
(FlowableProcessor<SchedulerWhen.ScheduledAction> actionProcessor, Scheduler.Worker actualWorker) -
Uses of FlowableProcessor in io.reactivex.rxjava3.processors
Subclasses of FlowableProcessor in io.reactivex.rxjava3.processorsModifier and TypeClassDescriptionfinal class
Processor that emits the very last value followed by a completion event or the received error toSubscriber
s.final class
Processor that emits the most recent item it has observed and all subsequent observed items to each subscribedSubscriber
.final class
AFlowableProcessor
implementation that coordinates downstream requests through a front-buffer and stable-prefetching, optionally canceling the upstream if all subscribers have cancelled.final class
Processor that multicasts all subsequently observed items to its currentSubscriber
s.final class
Replays events to Subscribers.(package private) final class
Serializes calls to the Subscriber methods.final class
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 FlowableProcessorModifier and TypeFieldDescription(package private) final FlowableProcessor
<T> SerializedProcessor.actual
The actual subscriber to serialize Subscriber calls to.Methods in io.reactivex.rxjava3.processors that return FlowableProcessorModifier and TypeMethodDescriptionfinal @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 FlowableProcessorModifierConstructorDescription(package private)
SerializedProcessor
(FlowableProcessor<T> actual) Constructor that wraps an actual subject.