Package | Description |
---|---|
reactor.core.publisher |
Modifier and Type | Class and Description |
---|---|
static class |
Operators.MonoSubscriber<I,O>
A Subscriber/Subscription barrier that holds a single value at most and properly gates asynchronous behaviors
resulting from concurrent request or cancel and onXXX signals.
|
class |
ReplayProcessor<T>
Deprecated.
To be removed in 3.5, prefer clear cut usage of
Sinks through
variations under Sinks.many().replay() . |
class |
UnicastProcessor<T>
Deprecated.
to be removed in 3.5, prefer clear cut usage of
Sinks through
variations under Sinks.many().unicast() . |