Uses of Class
reactor.core.publisher.SignalType

Packages that use SignalType

Package	Description
reactor.core.observability
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.

Uses of SignalType in reactor.core.observability

Methods in reactor.core.observability with parameters of type SignalType

Modifier and Type	Method and Description
void	DefaultSignalListener.doFinally(SignalType terminationType)
void	SignalListener.doFinally(SignalType terminationType) Handle terminal signals after the signals have been propagated, as the final step.

Uses of SignalType in reactor.core.publisher

Methods in reactor.core.publisher that return SignalType

Modifier and Type	Method and Description
SignalType	Signal.getType() Read the type of this signal: ON_SUBSCRIBE, ON_NEXT, ON_ERROR, or ON_COMPLETE
static SignalType	SignalType.valueOf(String name) Returns the enum constant of this type with the specified name.
static SignalType[]	SignalType.values() Returns an array containing the constants of this enum type, in the order they are declared.

Methods in reactor.core.publisher with parameters of type SignalType

Modifier and Type	Method and Description
protected void	BaseSubscriber.hookFinally(SignalType type) Optional hook executed after any of the termination events (onError, onComplete, cancel).
Flux<T>	Flux.log(Logger logger, Level level, boolean showOperatorLine, SignalType... options) Observe Reactive Streams signals matching the passed filter options and trace them using a specific user-provided Logger, at the given Level.
Mono<T>	Mono.log(Logger logger, Level level, boolean showOperatorLine, SignalType... options) Observe Reactive Streams signals matching the passed filter options and trace them using a specific user-provided Logger, at the given Level.
Flux<T>	Flux.log(String category, Level level, boolean showOperatorLine, SignalType... options) Observe Reactive Streams signals matching the passed filter options and trace them using Logger support.
ParallelFlux<T>	ParallelFlux.log(String category, Level level, boolean showOperatorLine, SignalType... options) Observe Reactive Streams signals matching the passed filter options and use Logger support to handle trace implementation.
Mono<T>	Mono.log(String category, Level level, boolean showOperatorLine, SignalType... options) Observe Reactive Streams signals matching the passed filter options and use Logger support to handle trace implementation.
Flux<T>	Flux.log(String category, Level level, SignalType... options) Observe Reactive Streams signals matching the passed filter options and trace them using Logger support.
ParallelFlux<T>	ParallelFlux.log(String category, Level level, SignalType... options) Observe Reactive Streams signals matching the passed filter options and use Logger support to handle trace implementation.
Mono<T>	Mono.log(String category, Level level, SignalType... options) Observe Reactive Streams signals matching the passed flags options and use Logger support to handle trace implementation.
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).

Method parameters in reactor.core.publisher with type arguments of type SignalType

Modifier and Type	Method and Description
Flux<T>	Flux.doFinally(Consumer<SignalType> onFinally) Add behavior (side-effect) triggered after the Flux terminates for any reason, including cancellation.
Mono<T>	Mono.doFinally(Consumer<SignalType> onFinally) Add behavior triggering after the Mono terminates for any reason, including cancellation.