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()
default ContextView	contextView() Return the current subscriber's context as a ContextView for inspection.
Context	currentContext() Deprecated. To be removed in 3.6.0 at the earliest. Prefer using #getContextView() instead.
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

@Deprecated
Context currentContext()

Deprecated. To be removed in 3.6.0 at the earliest. Prefer using #getContextView() instead.

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.

contextView

default ContextView contextView()

Return the current subscriber's context as a ContextView for inspection.

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

Returns:

the current subscriber ContextView.

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)