reactor.core.publisher

Interface SynchronousSink<T>

Type Parameters:

T - the output value type

public interface SynchronousSink<T>

Interface to produce synchronously "one signal" to an underlying Subscriber.

At most one next(T) call and/or one complete() or error(Throwable) should be called per invocation of the generator function.

Calling a SynchronousSink outside of a generator consumer or function, e.g. using an async callback, is forbidden. You can FluxSink or MonoSink based generators for these situations.

Method Summary

Modifier and Type	Method and Description
void	complete()
Context	currentContext() Return the current subscriber Context.
void	error(Throwable e)
void	next(T t) Try emitting, might throw an unchecked exception.

Method Detail

complete

void complete()

See Also:

Subscriber.onComplete()

currentContext

Context currentContext()

Return the current subscriber Context.

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

Returns:

the current subscriber Context.

error

void error(Throwable e)

Parameters:

e - the exception to signal, not null

See Also:

Subscriber.onError(Throwable)

next

void next(T t)

Try emitting, might throw an unchecked exception.

Parameters:

t - the value to emit, not null

Throws:

RuntimeException - in case of unchecked error during the emission

See Also:

Subscriber.onNext(Object)