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

success

void success()

Complete without any value.

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

success

void success(T value)

Complete with the given value.

Calling this method multiple times or after the other terminating methods has no effect. 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 has no effect.

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