reactor.core.publisher

Interface MonoSink<T>

Type Parameters:

T - the value type emitted

public interface MonoSink<T>

Wrapper API around an actual downstream Subscriber for emitting nothing, a single value or an error (mutually exclusive).

Method Summary

Modifier and Type	Method and Description
Context	currentContext() Return the current subscriber Context.
void	error(Throwable e) Terminate with the give exception
MonoSink<T>	onCancel(Disposable d) Associates a disposable resource with this MonoSink that will be disposed on downstream.cancel().
MonoSink<T>	onDispose(Disposable d) Associates a disposable resource with this MonoSink that will be disposed on the first terminate signal which may be a cancel, complete or error signal.
MonoSink<T>	onRequest(LongConsumer consumer) Attaches a LongConsumer to this MonoSink that will be notified of any request to this sink.
void	success() Complete without any value.
void	success(T value) Complete with the given value.

Method Detail

currentContext

Context currentContext()

Return the current subscriber Context.

Context can be enriched via Mono.subscriberContext(Function) operator or directly by a child subscriber overriding CoreSubscriber.currentContext()

Returns:

the current subscriber Context.

success

void success()

Complete without any value.

Calling this method multiple times or after the other terminating methods has no effect.

success

void success(@Nullable
             T value)

Complete with the given value.

Calling this method multiple times or after the other terminating methods has no effect (the value is purely ignored). Calling this method with a null value will be silently accepted as a call to success() by standard implementations.

Parameters:

value - the value to complete with

error

void error(Throwable e)

Terminate with the give exception

Calling this method multiple times or after the other terminating methods is an unsupported operation. It will discard the exception through the Hooks.onErrorDropped(Consumer) hook (which by default throws the exception wrapped via Exceptions.bubble(Throwable)). This is to avoid complete and silent swallowing of the exception.

Parameters:

e - the exception to complete with

onRequest

MonoSink<T> onRequest(LongConsumer consumer)

Attaches a LongConsumer to this MonoSink that will be notified of any request to this sink.

Parameters:

consumer - the consumer to invoke on each request

Returns:

MonoSink with a consumer that is notified of requests

onCancel

MonoSink<T> onCancel(Disposable d)

Associates a disposable resource with this MonoSink that will be disposed on downstream.cancel().

Parameters:

d - the disposable callback to use

Returns:

the MonoSink with resource to be disposed on cancel signal

onDispose

MonoSink<T> onDispose(Disposable d)

Associates a disposable resource with this MonoSink that will be disposed on the first terminate signal which may be a cancel, complete or error signal.

Parameters:

d - the disposable callback to use

Returns:

the MonoSink with resource to be disposed on first terminate signal