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 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 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 to Subscribers.
class	BehaviorProcessor<T>	Processor that emits the most recent item it has observed and all subsequent observed items to each subscribed Subscriber.
class	MulticastProcessor<T>	A FlowableProcessor 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 current Subscribers.
class	ReplayProcessor<T>	Replays events to Subscribers.
(package private) class	SerializedProcessor<T>	Serializes calls to the Subscriber methods.
class	UnicastProcessor<T>	A FlowableProcessor variant that queues up events until a single Subscriber subscribes to it, replays those events to it until the Subscriber catches up and then switches to relaying events live to this single Subscriber until this UnicastProcessor terminates or the Subscriber 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.