Package | Description |
---|---|
reactor.rx |
Streams are reactive components derived from Reactive Extensions and implementing Reactive Streams specification.
|
reactor.rx.action.combination |
Modifier and Type | Method and Description |
---|---|
<T,V> Stream<V> |
Stream.fanIn(FanInAction<T,?,V,? extends FanInAction.InnerSubscriber<T,?,V>> fanInAction)
Stream.lift(Supplier) all the nested Publisher values to a new Stream calling the logic
inside the provided fanInAction for complex merging strategies. |
Modifier and Type | Class and Description |
---|---|
class |
CombineLatestAction<O,V,TUPLE extends Tuple> |
class |
MergeAction<O> |
class |
ZipAction<O,V,TUPLE extends Tuple> |
Modifier and Type | Method and Description |
---|---|
FanInAction<I,?,O,? extends FanInAction.InnerSubscriber<I,?,O>> |
DynamicMergeAction.mergedStream() |
Constructor and Description |
---|
DynamicMergeAction(FanInAction<I,?,O,? extends FanInAction.InnerSubscriber<I,?,O>> fanInAction) |
Copyright © 2016. All rights reserved.