Uses of Package
io.reactivex.rxjava3.processors
Packages that use io.reactivex.rxjava3.processors
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
.-
Classes in io.reactivex.rxjava3.processors used by io.reactivex.rxjava3.internal.operators.flowableClassDescriptionRepresents a Subscriber and a Flowable (Publisher) at the same time, allowing multicasting events from a single source to multiple child Subscribers.A
FlowableProcessor
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. -
Classes in io.reactivex.rxjava3.processors used by io.reactivex.rxjava3.internal.schedulersClassDescriptionRepresents a Subscriber and a Flowable (Publisher) at the same time, allowing multicasting events from a single source to multiple child Subscribers.
-
Classes in io.reactivex.rxjava3.processors used by io.reactivex.rxjava3.processorsClassDescriptionProcessor that emits the very last value followed by a completion event or the received error to
Subscriber
s.Processor that emits the most recent item it has observed and all subsequent observed items to each subscribedSubscriber
.Represents a Subscriber and a Flowable (Publisher) at the same time, allowing multicasting events from a single source to multiple child Subscribers.AFlowableProcessor
implementation that coordinates downstream requests through a front-buffer and stable-prefetching, optionally canceling the upstream if all subscribers have cancelled.Processor that multicasts all subsequently observed items to its currentSubscriber
s.Wraps the actual subscriber, tracks its requests and makes cancellation to remove itself from the current subscribers array.Replays events to Subscribers.Abstraction over a buffer that receives events and replays them to individual Subscribers.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.