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 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 FlowableProcessor

Modifier	Constructor	Description
(package private)	FlowableWindowSubscribeIntercept(FlowableProcessor<T> source)
(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 FlowableProcessor

Modifier and Type	Field	Description
private 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 FlowableProcessor

Modifier	Constructor	Description
(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.processors

Modifier and Type	Class	Description
final class	AsyncProcessor<T>	Processor that emits the very last value followed by a completion event or the received error to Subscribers.
final class	BehaviorProcessor<T>	Processor that emits the most recent item it has observed and all subsequent observed items to each subscribed Subscriber.
final 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.
final class	PublishProcessor<T>	Processor that multicasts all subsequently observed items to its current Subscribers.
final class	ReplayProcessor<T>	Replays events to Subscribers.
(package private) final class	SerializedProcessor<T>	Serializes calls to the Subscriber methods.
final 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) final 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
final @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

Modifier	Constructor	Description
(package private)	SerializedProcessor(FlowableProcessor<T> actual)	Constructor that wraps an actual subject.