reactor.core.publisher

Class Sinks

java.lang.Object

reactor.core.publisher.Sinks

public final class Sinks
extends Object

A collection of standalone sinks (Sinks.StandaloneFluxSink and Sinks.StandaloneMonoSink).

Author:

Simon Baslé

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	Sinks.StandaloneFluxSink<T> A flavor of SequenceSink that is not attached to a single Subscriber but rather viewable as a Flux.
static interface	Sinks.StandaloneMonoSink<T> A flavor of ScalarSink that is not attached to a single Subscriber but rather viewable as a Mono.

Method Summary

Modifier and Type	Method and Description
static <T> Sinks.StandaloneFluxSink<T>	multicast() A Sinks.StandaloneFluxSink with the following characteristics: Multicast Backpressure : this sink honors downstream demand by conforming to the lowest demand in case of multiple subscribers. Replaying: No replay.
static <T> Sinks.StandaloneFluxSink<T>	multicastNoWarmup() A Sinks.StandaloneFluxSink with the following characteristics: Multicast Backpressure : this sink honors downstream demand of individual subscribers. Replaying: No replay.
static <T> Sinks.StandaloneMonoSink<T>	promise() A Sinks.StandaloneMonoSink that works like a conceptual Promise: it can be completed at any time, but only once.
static <T> Sinks.StandaloneFluxSink<T>	replay(int historySize) A Sinks.StandaloneFluxSink with the following characteristics: Multicast Backpressure : this sink honors downstream demand of individual subscribers. Replaying: by historySize.
static <T> Sinks.StandaloneFluxSink<T>	replayAll() A Sinks.StandaloneFluxSink with the following characteristics: Multicast Backpressure : this sink honors downstream demand of individual subscribers. Replaying: all elements pushed to this sink are replayed to new subscribers. Without Subscriber: all elements pushed to this sink are remembered, even when there is no subscriber.
static <T> Sinks.StandaloneFluxSink<T>	unicast() A Sinks.StandaloneFluxSink with the following characteristics: Unicast: contrary to most other Sinks.StandaloneFluxSink, the Flux view rejects subscribers past the first one. Backpressure : this sink honors downstream demand of its single Subscriber. Replaying: non-applicable, since only one Subscriber can register. Without Subscriber: all elements pushed to this sink are remembered and will be replayed once the Subscriber subscribes.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

multicast

public static <T> Sinks.StandaloneFluxSink<T> multicast()

A Sinks.StandaloneFluxSink with the following characteristics:

• Multicast
• Backpressure : this sink honors downstream demand by conforming to the lowest demand in case of multiple subscribers.
• Replaying: No replay. Only forwards to a Subscriber the elements that have been pushed to the sink AFTER this subscriber was subscribed. To the exception of the first subscriber (see below).
• Without Subscriber: warm up. Remembers up to Queues.SMALL_BUFFER_SIZE elements pushed before the first Subscriber is registered.

multicastNoWarmup

public static <T> Sinks.StandaloneFluxSink<T> multicastNoWarmup()

A Sinks.StandaloneFluxSink with the following characteristics:

• Multicast
• Backpressure : this sink honors downstream demand of individual subscribers.
• Replaying: No replay. Only forwards to a Subscriber the elements that have been pushed to the sink AFTER this subscriber was subscribed.
• Without Subscriber: Discarding. Pushing elements while there are no Subscriber registered will simply discard these elements instead of "warming up" the sink.

promise

public static <T> Sinks.StandaloneMonoSink<T> promise()

A Sinks.StandaloneMonoSink that works like a conceptual Promise: it can be completed at any time, but only once. This is done by invoking either of the three completions: valued completion, empty completions or error. This completion is replayed to late subscribers.

replay

public static <T> Sinks.StandaloneFluxSink<T> replay(int historySize)

A Sinks.StandaloneFluxSink with the following characteristics:

• Multicast
• Backpressure : this sink honors downstream demand of individual subscribers.
• Replaying: by historySize. Keeps the last historySize elements and replays them instantly to new subscribers before continuing with "live" elements.
• Without Subscriber: buffers enough elements pushed without a subscriber to honor the historySize.

replayAll

public static <T> Sinks.StandaloneFluxSink<T> replayAll()

A Sinks.StandaloneFluxSink with the following characteristics:

• Multicast
• Backpressure : this sink honors downstream demand of individual subscribers.
• Replaying: all elements pushed to this sink are replayed to new subscribers.
• Without Subscriber: all elements pushed to this sink are remembered, even when there is no subscriber.

unicast

public static <T> Sinks.StandaloneFluxSink<T> unicast()

A Sinks.StandaloneFluxSink with the following characteristics:

• Unicast: contrary to most other Sinks.StandaloneFluxSink, the Flux view rejects subscribers past the first one.
• Backpressure : this sink honors downstream demand of its single Subscriber.
• Replaying: non-applicable, since only one Subscriber can register.
• Without Subscriber: all elements pushed to this sink are remembered and will be replayed once the Subscriber subscribes.