Uses of Interface
reactor.core.publisher.Signal

Packages that use Signal

Package	Description
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.test	Main test components supporting the testing and assertion of publishers.
reactor.test.subscriber	Components supporting the creation of test-oriented Subscribers.

Uses of Signal in reactor.core.publisher

Methods in reactor.core.publisher that return Signal

Modifier and Type	Method and Description
static <T> Signal<T>	Signal.complete() Creates and returns a Signal of variety Type.COMPLETE.
static <T> Signal<T>	Signal.complete(Context context) Creates and returns a Signal of variety Type.COMPLETE, associated with a specific Context.
static <T> Signal<T>	Signal.error(Throwable e) Creates and returns a Signal of variety Type.FAILED, which holds the error.
static <T> Signal<T>	Signal.error(Throwable e, Context context) Creates and returns a Signal of variety Type.FAILED, which holds the error and the Context associated with the erroring source.
static <T> Signal<T>	Signal.next(T t) Creates and returns a Signal of variety Type.NEXT, which holds the value.
static <T> Signal<T>	Signal.next(T t, Context context) Creates and returns a Signal of variety Type.NEXT, which holds the value and the Context associated with the emitting source.
static <T> Signal<T>	Signal.subscribe(Subscription subscription) Creates and returns a Signal of variety Type.ON_SUBSCRIBE.
static <T> Signal<T>	Signal.subscribe(Subscription subscription, Context context) Creates and returns a Signal of variety Type.ON_SUBSCRIBE, that holds the Context associated with the subscribed source.

Methods in reactor.core.publisher that return types with arguments of type Signal

Modifier and Type	Method and Description
Mono<Signal<T>>	Mono.materialize() Transform incoming onNext, onError and onComplete signals into Signal instances, materializing these signals.
Flux<Signal<T>>	Flux.materialize() Transform incoming onNext, onError and onComplete signals into Signal instances, materializing these signals.

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

Modifier and Type	Method and Description
ParallelFlux<T>	ParallelFlux.doOnEach(Consumer<? super Signal<T>> signalConsumer) Triggers side-effects when the ParallelFlux emits an item, fails with an error or completes successfully.
Mono<T>	Mono.doOnEach(Consumer<? super Signal<T>> signalConsumer) Add behavior triggered when the Mono emits an item, fails with an error or completes successfully.
Flux<T>	Flux.doOnEach(Consumer<? super Signal<T>> signalConsumer) Add behavior (side-effects) triggered when the Flux emits an item, fails with an error or completes successfully.
<V> Flux<V>	Flux.switchOnFirst(BiFunction<Signal<? extends T>,Flux<T>,Publisher<? extends V>> transformer) Transform the current Flux once it emits its first element, making a conditional transformation possible.
<V> Flux<V>	Flux.switchOnFirst(BiFunction<Signal<? extends T>,Flux<T>,Publisher<? extends V>> transformer, boolean cancelSourceOnComplete) Transform the current Flux once it emits its first element, making a conditional transformation possible.

Uses of Signal in reactor.test

Methods in reactor.test that return types with arguments of type Signal

Modifier and Type	Method and Description
static ValueFormatters.Extractor<Signal>	ValueFormatters.signalExtractor() Default Signal extractor that unwraps only onNext.

Uses of Signal in reactor.test.subscriber

Methods in reactor.test.subscriber that return Signal

Modifier and Type	Method and Description
Signal<T>	TestSubscriber.expectTerminalSignal() Expect the TestSubscriber to be terminated, and return the terminal Signal if so.
Signal<T>	TestSubscriber.getTerminalSignal() Return the terminal Signal if this TestSubscriber TestSubscriber.isTerminated(), or null otherwise.

Methods in reactor.test.subscriber that return types with arguments of type Signal

Modifier and Type	Method and Description
List<Signal<T>>	TestSubscriber.getProtocolErrors() Return a List of Signal which represent detected protocol error from the source Publisher, that is to say signals that were emitted to this TestSubscriber in violation of the Reactive Streams specification.