Package | Description |
---|---|
io.reactivex.processors |
Classes extending the Flowable base reactive class and implementing
the Subscriber interface at the same time (aka hot Flowables).
|
Modifier and Type | Class and Description |
---|---|
class |
AsyncProcessor<T>
Processor that emits the very last value followed by a completion event or the received error
to
Subscriber s. |
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
Subscriber s. |
class |
ReplayProcessor<T>
Replays events to Subscribers.
|
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. |
Modifier and Type | Method and Description |
---|---|
FlowableProcessor<T> |
FlowableProcessor.toSerialized()
Wraps this FlowableProcessor and serializes the calls to the onSubscribe, onNext, onError and
onComplete methods, making them thread-safe.
|
Copyright © 2019. All rights reserved.