public static interface Sinks.RootSpec
| 限定符和类型 | 方法和说明 |
|---|---|
<T> Sinks.Empty<T> |
empty()
A
Sinks.Empty which exclusively produces one terminal signal: error or complete. |
Sinks.ManySpec |
many()
Help building
Sinks.Many sinks that will broadcast multiple signals to one or more Subscriber. |
Sinks.ManyWithUpstreamUnsafeSpec |
manyWithUpstream()
|
<T> Sinks.One<T> |
one()
A
Sinks.One that works like a conceptual promise: it can be completed
with or without a value at any time, but only once. |
<T> Sinks.Empty<T> empty()
Sinks.Empty which exclusively produces one terminal signal: error or complete.
It has the following characteristics:
Sinks.Empty.asMono() to expose the Mono view of the sink to downstream consumers.<T> Sinks.One<T> one()
Sinks.One that works like a conceptual promise: it can be completed
with or without a value at any time, but only once. This completion is replayed to late subscribers.
Calling Sinks.One.emitValue(Object, Sinks.EmitFailureHandler) (or
Sinks.One.tryEmitValue(Object)) is enough and will implicitly produce
a Subscriber.onComplete() signal as well.
Use Sinks.Empty.asMono() to expose the Mono view of the sink to downstream consumers.
Sinks.ManySpec many()
Sinks.Many sinks that will broadcast multiple signals to one or more Subscriber.
Use Sinks.Many.asFlux() to expose the Flux view of the sink to the downstream consumers.
Sinks.ManySpecSinks.ManyWithUpstreamUnsafeSpec manyWithUpstream()
Sinks.ManyWithUpstream sinks that can also be subscribed to
an upstream Publisher. This is an advanced use case, see Sinks.ManyWithUpstream.subscribeTo(Publisher).