程序包 | 说明 |
---|---|
reactor.core.publisher |
限定符和类型 | 方法和说明 |
---|---|
Sinks.EmitResult |
Sinks.EmissionException.getReason()
Get the failure
Sinks.EmitResult code that is represented by this exception. |
Sinks.EmitResult |
EmitterProcessor.tryEmitComplete()
已过时。
|
Sinks.EmitResult |
ReplayProcessor.tryEmitComplete()
已过时。
|
Sinks.EmitResult |
UnicastProcessor.tryEmitComplete()
已过时。
|
Sinks.EmitResult |
Sinks.Many.tryEmitComplete()
Try to terminate the sequence successfully, generating an
onComplete
signal. |
Sinks.EmitResult |
Sinks.Empty.tryEmitEmpty()
Try to complete the
Mono without a value, generating only an onComplete signal. |
Sinks.EmitResult |
EmitterProcessor.tryEmitError(java.lang.Throwable t)
已过时。
|
Sinks.EmitResult |
ReplayProcessor.tryEmitError(java.lang.Throwable t)
已过时。
|
Sinks.EmitResult |
UnicastProcessor.tryEmitError(java.lang.Throwable t)
已过时。
|
Sinks.EmitResult |
Sinks.Many.tryEmitError(java.lang.Throwable error)
Try to fail the sequence, generating an
onError
signal. |
Sinks.EmitResult |
Sinks.Empty.tryEmitError(java.lang.Throwable error)
Try to fail the
Mono , generating only an onError signal. |
Sinks.EmitResult |
EmitterProcessor.tryEmitNext(T t)
已过时。
|
Sinks.EmitResult |
ReplayProcessor.tryEmitNext(T t)
已过时。
|
Sinks.EmitResult |
UnicastProcessor.tryEmitNext(T t)
已过时。
|
Sinks.EmitResult |
Sinks.Many.tryEmitNext(T t)
Try emitting a non-null element, generating an
onNext signal. |
Sinks.EmitResult |
Sinks.One.tryEmitValue(T value)
Try to complete the
Mono with an element, generating an onNext signal
immediately followed by an onComplete signal. |
Sinks.EmitResult |
SinkOneSerialized.tryEmitValue(T t) |
static Sinks.EmitResult |
Sinks.EmitResult.valueOf(java.lang.String name)
返回带有指定名称的该类型的枚举常量。
|
static Sinks.EmitResult[] |
Sinks.EmitResult.values()
按照声明该枚举类型的常量的顺序, 返回
包含这些常量的数组。
|
限定符和类型 | 方法和说明 |
---|---|
boolean |
Sinks.EmitFailureHandler.onEmitFailure(SignalType signalType,
Sinks.EmitResult emitResult)
Decide whether the emission should be retried, depending on the provided
Sinks.EmitResult
and the type of operation that was attempted (represented as a SignalType ). |
构造器和说明 |
---|
EmissionException(Sinks.EmitResult reason) |
EmissionException(Sinks.EmitResult reason,
java.lang.String message) |
EmissionException(java.lang.Throwable cause,
Sinks.EmitResult reason) |