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 |
Modifier and Type | Method and Description |
---|---|
Stream<Signal<O>> |
Stream.materialize()
Transform the incoming onSubscribe, onNext, onError and onComplete signals into
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. |
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 . |
Constructor and Description |
---|
FinallyAction(Consumer<Signal<T>> consumer) |
Modifier and Type | Method and Description |
---|---|
protected void |
DematerializeAction.doNext(Signal<T> ev) |
Copyright © 2016. All rights reserved.