Uses of Class
reactor.rx.action.Signal

Packages that use Signal

Package	Description
reactor.rx	Streams are reactive components derived from Reactive Extensions and implementing Reactive Streams specification.
reactor.rx.action	Actions are Reactive Streams components derived from Reactive Extensions and beyond.
reactor.rx.action.passive
reactor.rx.action.transformation

Uses of Signal in reactor.rx

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

Modifier and Type	Method and Description
Stream<Signal<O>>	Stream.materialize() Transform the incoming onSubscribe, onNext, onError and onComplete signals into Signal.

Method parameters in reactor.rx with type arguments of type Signal

Modifier and Type	Method and Description
Stream<O>	Stream.finallyDo(Consumer<Signal<O>> consumer) Attach a Consumer to this Stream that will observe terminal signal complete|error.

Uses of Signal in reactor.rx.action

Methods in reactor.rx.action 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.error(Throwable e) Creates and returns a Signal of variety Type.ERROR, and assigns it an exception.
static <T> Signal<T>	Signal.next(T t) Creates and returns a Signal of variety Type.NEXT, and assigns it a value.
static <T> Signal<T>	Signal.subscribe(org.reactivestreams.Subscription subscription) Creates and returns a Signal of variety Type.COMPLETE.

Uses of Signal in reactor.rx.action.passive

Constructor parameters in reactor.rx.action.passive with type arguments of type Signal

Constructor and Description
FinallyAction(Consumer<Signal<T>> consumer)

Uses of Signal in reactor.rx.action.transformation

Methods in reactor.rx.action.transformation with parameters of type Signal

Modifier and Type	Method and Description
protected void	DematerializeAction.doNext(Signal<T> ev)