| 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(). |