接口的使用
reactor.core.publisher.Sinks.EmitFailureHandler

使用Sinks.EmitFailureHandler的程序包

程序包	说明
reactor.core.publisher	Provide main Reactive APIs in Flux and Mono, as well as various helper classes, interfaces used in the composition API, variants of Flux and operator-building utilities.

reactor.core.publisher中Sinks.EmitFailureHandler的使用

声明为Sinks.EmitFailureHandler的reactor.core.publisher中的字段

限定符和类型	字段和说明
static Sinks.EmitFailureHandler	Sinks.EmitFailureHandler.FAIL_FAST A pre-made handler that will not instruct to retry any failure and trigger the failure handling immediately.

返回Sinks.EmitFailureHandler的reactor.core.publisher中的方法

限定符和类型	方法和说明
static Sinks.EmitFailureHandler	Sinks.EmitFailureHandler.busyLooping(java.time.Duration duration) Create an Sinks.EmitFailureHandler which will busy loop in case of concurrent use of the sink (Sinks.EmitResult.FAIL_NON_SERIALIZED, up to a deadline.

参数类型为Sinks.EmitFailureHandler的reactor.core.publisher中的方法

限定符和类型	方法和说明
void	Sinks.Many.emitComplete(Sinks.EmitFailureHandler failureHandler) A simplified attempt at completing via the Sinks.Many.tryEmitComplete() API, generating an onComplete signal.
void	Sinks.Empty.emitEmpty(Sinks.EmitFailureHandler failureHandler) A simplified attempt at completing via the Sinks.Empty.tryEmitEmpty() API, generating an onComplete signal.
void	Sinks.Many.emitError(java.lang.Throwable error, Sinks.EmitFailureHandler failureHandler) A simplified attempt at failing the sequence via the Sinks.Many.tryEmitError(Throwable) API, generating an onError signal.
void	Sinks.Empty.emitError(java.lang.Throwable error, Sinks.EmitFailureHandler failureHandler) A simplified attempt at failing the sequence via the Sinks.Empty.tryEmitError(Throwable) API, generating an onError signal.
void	UnicastProcessor.emitNext(T value, Sinks.EmitFailureHandler failureHandler) 已过时。
void	Sinks.Many.emitNext(T t, Sinks.EmitFailureHandler failureHandler) A simplified attempt at emitting a non-null element via the Sinks.Many.tryEmitNext(Object) API, generating an onNext signal.
void	Sinks.One.emitValue(T value, Sinks.EmitFailureHandler failureHandler) A simplified attempt at emitting a non-null element via the Sinks.One.tryEmitValue(Object) API, generating an onNext signal immediately followed by an Subscriber.onComplete() signal.