Uses of Interface
reactor.core.publisher.Sinks.Many

Packages that use Sinks.Many

Package	Description
reactor.core.publisher	Provide main Reactive APIs in Flux and Mono, as well as various helper classes, interfaces used in the composition API, variants of Flux and operator-building utilities.

Uses of Sinks.Many in reactor.core.publisher

Subinterfaces of Sinks.Many in reactor.core.publisher

Modifier and Type	Interface and Description
static interface	Sinks.ManyWithUpstream<T> A Sinks.Many which additionally allows being subscribed to an upstream Publisher, which is an advanced pattern requiring external synchronization.

Classes in reactor.core.publisher that implement Sinks.Many

Modifier and Type

Class and Description

class

EmitterProcessor<T> Deprecated. To be removed in 3.5. Prefer clear cut usage of Sinks through variations of Sinks.many().multicast().onBackpressureBuffer(). If you really need the subscribe-to-upstream functionality of a Processor, switch to Sinks.ManyWithUpstream with Sinks.unsafe() variants of Sinks.unsafe().manyWithUpstream(). This processor was blocking in EmitterProcessor.onNext(Object). This behaviour can be implemented with the Sinks API by calling tryEmitNext(Object) and retrying, e.g.: while (sink.tryEmitNext(v).hasFailed()) { LockSupport.parkNanos(10); }

Methods in reactor.core.publisher that return Sinks.Many

Modifier and Type	Method and Description
<T> Sinks.Many<T>	Sinks.MulticastReplaySpec.all() A Sinks.Many with the following characteristics: Multicast Without Subscriber: all elements pushed to this sink are remembered, even when there is no subscriber. Backpressure : this sink honors downstream demand of individual subscribers. Replaying: all elements pushed to this sink are replayed to new subscribers.
<T> Sinks.Many<T>	Sinks.MulticastReplaySpec.all(int batchSize) A Sinks.Many with the following characteristics: Multicast Without Subscriber: all elements pushed to this sink are remembered, even when there is no subscriber. Backpressure : this sink honors downstream demand of individual subscribers. Replaying: all elements pushed to this sink are replayed to new subscribers.
<T> Sinks.Many<T>	Sinks.MulticastSpec.directAllOrNothing() A Sinks.Many with the following characteristics: Multicast Without Subscriber: fail fast on tryEmitNext. Backpressure : notify the caller with Sinks.EmitResult.FAIL_OVERFLOW if any of the subscribers cannot process an element, failing fast and backing off from emitting the element at all (all or nothing).
<T> Sinks.Many<T>	Sinks.MulticastSpec.directBestEffort() A Sinks.Many with the following characteristics: Multicast Without Subscriber: fail fast on tryEmitNext. Backpressure : notify the caller with Sinks.EmitResult.FAIL_OVERFLOW if none of the subscribers can process an element.
<T> Sinks.Many<T>	Sinks.MulticastReplaySpec.latest() A Sinks.Many with the following characteristics: Multicast Without Subscriber: the latest element pushed to this sink are remembered, even when there is no subscriber.
<T> Sinks.Many<T>	Sinks.MulticastReplaySpec.latestOrDefault(T value) A Sinks.Many with the following characteristics: Multicast Without Subscriber: the latest element pushed to this sink are remembered, even when there is no subscriber. Backpressure : this sink honors downstream demand of individual subscribers. Replaying: the latest element pushed to this sink is replayed to new subscribers.
<T> Sinks.Many<T>	Sinks.MulticastReplaySpec.limit(Duration maxAge) A Sinks.Many with the following characteristics: Multicast Without Subscriber: all elements pushed to this sink are remembered until their maxAge is reached, even when there is no subscriber.
<T> Sinks.Many<T>	Sinks.MulticastReplaySpec.limit(Duration maxAge, Scheduler scheduler) A Sinks.Many with the following characteristics: Multicast Without Subscriber: all elements pushed to this sink are remembered until their maxAge is reached, even when there is no subscriber.
<T> Sinks.Many<T>	Sinks.MulticastReplaySpec.limit(int historySize) A Sinks.Many with the following characteristics: Multicast Without Subscriber: up to historySize elements pushed to this sink are remembered, even when there is no subscriber.
<T> Sinks.Many<T>	Sinks.MulticastReplaySpec.limit(int historySize, Duration maxAge) A Sinks.Many with the following characteristics: Multicast Without Subscriber: up to historySize elements pushed to this sink are remembered, until their maxAge is reached, even when there is no subscriber.
<T> Sinks.Many<T>	Sinks.MulticastReplaySpec.limit(int historySize, Duration maxAge, Scheduler scheduler) A Sinks.Many with the following characteristics: Multicast Without Subscriber: up to historySize elements pushed to this sink are remembered, until their maxAge is reached, even when there is no subscriber.
<T> Sinks.Many<T>	Sinks.UnicastSpec.onBackpressureBuffer() A Sinks.Many with the following characteristics: Unicast: contrary to most other Sinks.Many, 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.
<T> Sinks.Many<T>	Sinks.MulticastSpec.onBackpressureBuffer() A Sinks.Many with the following characteristics: Multicast Without Subscriber: warm up.
<T> Sinks.Many<T>	Sinks.MulticastSpec.onBackpressureBuffer(int bufferSize) A Sinks.Many with the following characteristics: Multicast Without Subscriber: warm up.
<T> Sinks.Many<T>	Sinks.MulticastSpec.onBackpressureBuffer(int bufferSize, boolean autoCancel) A Sinks.Many with the following characteristics: Multicast Without Subscriber: warm up.
<T> Sinks.Many<T>	Sinks.UnicastSpec.onBackpressureBuffer(Queue<T> queue) A Sinks.Many with the following characteristics: Unicast: contrary to most other Sinks.Many, 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: depending on the queue, all elements pushed to this sink are remembered and will be replayed once the Subscriber subscribes.
<T> Sinks.Many<T>	Sinks.UnicastSpec.onBackpressureBuffer(Queue<T> queue, Disposable endCallback) A Sinks.Many with the following characteristics: Unicast: contrary to most other Sinks.Many, 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: depending on the queue, all elements pushed to this sink are remembered and will be replayed once the Subscriber subscribes.
<T> Sinks.Many<T>	Sinks.UnicastSpec.onBackpressureError() A Sinks.Many with the following characteristics: Unicast: contrary to most other Sinks.Many, the Flux view rejects subscribers past the first one. Backpressure : this sink honors downstream demand of the Subscriber, and will emit Subscriber.onError(Throwable) if there is a mismatch. Replaying: No replay.