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(java.lang.Throwable e) Terminate with the give exception
void	setCancellation(Cancellation c) Sets a cancellation callback triggered by downstreams cancel().
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.

Parameters:

value - the value to complete with

error

void error(java.lang.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

setCancellation

void setCancellation(Cancellation c)

Sets a cancellation callback triggered by downstreams cancel().

Calling this method more than once has no effect.

Parameters:

c - the cancellation callback