reactor.core.publisher

Interface Sinks.ManyWithUpstreamUnsafeSpec

Enclosing class:

Sinks

public static interface Sinks.ManyWithUpstreamUnsafeSpec

Instead of unsafe flavors of Sinks.Many, this spec provides Sinks.ManyWithUpstream implementations. These additionally support being subscribed to an upstream Publisher, at most once. Please note that when this is done, one MUST stop using emit/tryEmit APIs, reserving signal creation to be the sole responsibility of the upstream Publisher.

As the number of such implementations is deliberately kept low, this spec doesn't further distinguish between multicast/unicast/replay categories other than in method naming.

Method Summary

Modifier and Type	Method and Description
<T> Sinks.ManyWithUpstream<T>	multicastOnBackpressureBuffer() A Sinks.ManyWithUpstream with the following characteristics: Multicast Without Subscriber: warm up.
<T> Sinks.ManyWithUpstream<T>	multicastOnBackpressureBuffer(int bufferSize, boolean autoCancel) A Sinks.ManyWithUpstream with the following characteristics: Multicast Without Subscriber: warm up.

Method Detail

multicastOnBackpressureBuffer

<T> Sinks.ManyWithUpstream<T> multicastOnBackpressureBuffer()

A Sinks.ManyWithUpstream with the following characteristics:

• Multicast
• Without Subscriber: warm up. Remembers up to Queues.SMALL_BUFFER_SIZE elements pushed via Sinks.Many.tryEmitNext(Object) before the first Subscriber is registered.
• Backpressure : this sink honors downstream demand by conforming to the lowest demand in case of multiple subscribers.
  If the difference between multiple subscribers is greater than Queues.SMALL_BUFFER_SIZE:
  • tryEmitNext will return Sinks.EmitResult.FAIL_OVERFLOW
  • emitNext will terminate the sink by emitting an overflow error.
• Replaying: No replay of values seen by earlier subscribers. Only forwards to a Subscriber the elements that have been pushed to the sink AFTER this subscriber was subscribed, or elements that have been buffered due to backpressure/warm up.

multicastOnBackpressureBuffer

<T> Sinks.ManyWithUpstream<T> multicastOnBackpressureBuffer(int bufferSize,
                                                            boolean autoCancel)

A Sinks.ManyWithUpstream with the following characteristics:

• Multicast
• Without Subscriber: warm up. Remembers up to bufferSize elements pushed via Sinks.Many.tryEmitNext(Object) before the first Subscriber is registered.
• Backpressure : this sink honors downstream demand by conforming to the lowest demand in case of multiple subscribers.
  If the difference between multiple subscribers is too high compared to bufferSize:
  • tryEmitNext will return Sinks.EmitResult.FAIL_OVERFLOW
  • emitNext will terminate the sink by emitting an overflow error.
• Replaying: No replay of values seen by earlier subscribers. Only forwards to a Subscriber the elements that have been pushed to the sink AFTER this subscriber was subscribed, or elements that have been buffered due to backpressure/warm up.

Parameters:

bufferSize - the maximum queue size

autoCancel - should the sink fully shutdowns (not publishing anymore) when the last subscriber cancels