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 |
FanInAction<I,E,O,SUBSCRIBER extends FanInAction.InnerSubscriber<I,E,O>>
The best moment of my life so far, not.
|
class |
FanInSubscription<O,E,X,SUBSCRIBER extends FanInAction.InnerSubscriber<O,E,X>> |
static class |
FanInSubscription.InnerSubscription<O,E,SUBSCRIBER extends FanInAction.InnerSubscriber<O,E,?>> |
Modifier and Type | Class and Description |
---|---|
static class |
CombineLatestAction.InnerSubscriber<O,V> |
static class |
MergeAction.InnerSubscriber<I> |
static class |
ZipAction.InnerSubscriber<O,V> |
Modifier and Type | Method and Description |
---|---|
protected abstract FanInAction.InnerSubscriber<I,E,O> |
FanInAction.createSubscriber() |
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 © 2017. All rights reserved.