reactor.core.publisher

接口 SynchronousSink<T>

类型参数:

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.

方法概要

限定符和类型	方法和说明
void	complete()
default ContextView	contextView() Return the current subscriber's context as a ContextView for inspection.
Context	currentContext() 已过时。 To be removed in 3.6.0 at the earliest. Prefer using #getContextView() instead.
void	error(java.lang.Throwable e)
void	next(T t) Try emitting, might throw an unchecked exception.

方法详细资料

complete

void complete()

另请参阅:

Subscriber.onComplete()

currentContext

@Deprecated
Context currentContext()

已过时。 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()

返回:

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

返回:

the current subscriber ContextView.

error

void error(java.lang.Throwable e)

参数:

e - the exception to signal, not null

另请参阅:

Subscriber.onError(Throwable)

next

void next(T t)

Try emitting, might throw an unchecked exception.

参数:

t - the value to emit, not null

抛出:

java.lang.RuntimeException - in case of unchecked error during the emission

另请参阅:

Subscriber.onNext(Object)