程序包 | 说明 |
---|---|
reactor.core.publisher |
限定符和类型 | 类和说明 |
---|---|
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>
已过时。
To be removed in 3.5, prefer clear cut usage of
Sinks through
variations under Sinks.many().replay() . |
class |
UnicastProcessor<T>
已过时。
to be removed in 3.5, prefer clear cut usage of
Sinks through
variations under Sinks.many().unicast() . |