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