reactor.core.publisher

Interface Sinks.RootSpec

Enclosing class:

Sinks

public static interface Sinks.RootSpec

Provides a choice of Sinks.One/Sinks.Empty factories and further specs for Sinks.Many.

Method Summary

Modifier and Type	Method and Description
<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() Help building Sinks.ManyWithUpstream sinks that can also be subscribed to an upstream Publisher.
<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.

Method Detail

empty

<T> Sinks.Empty<T> empty()

A Sinks.Empty which exclusively produces one terminal signal: error or complete. It has the following characteristics:

• Multicast
• Backpressure : this sink does not need any demand since it can only signal error or completion
• Replaying: Replay the terminal signal (error or complete).

Use Sinks.Empty.asMono() to expose the Mono view of the sink to downstream consumers.

one

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

many

Sinks.ManySpec many()

Help building 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.

Returns:

Sinks.ManySpec

manyWithUpstream

Sinks.ManyWithUpstreamUnsafeSpec manyWithUpstream()

Help building Sinks.ManyWithUpstream sinks that can also be subscribed to an upstream Publisher. This is an advanced use case, see Sinks.ManyWithUpstream.subscribeTo(Publisher).

Returns:

a Sinks.ManyWithUpstreamUnsafeSpec