Package | Description |
---|---|
io.reactivex.processors |
Classes extending the Flowable base reactive class and implementing
the Subscriber interface at the same time (aka hot Flowables).
|
Class and Description |
---|
AsyncProcessor
Processor that emits the very last value followed by a completion event or the received error
to
Subscriber s. |
BehaviorProcessor
Processor that emits the most recent item it has observed and all subsequent observed items to each subscribed
Subscriber . |
FlowableProcessor
Represents a Subscriber and a Flowable (Publisher) at the same time, allowing
multicasting events from a single source to multiple child Subscribers.
|
MulticastProcessor
A
FlowableProcessor implementation that coordinates downstream requests through
a front-buffer and stable-prefetching, optionally canceling the upstream if all
subscribers have cancelled. |
PublishProcessor
Processor that multicasts all subsequently observed items to its current
Subscriber s. |
ReplayProcessor
Replays events to Subscribers.
|
UnicastProcessor
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. |
Copyright © 2018 JBoss by Red Hat. All rights reserved.