Uses of Class
reactor.rx.action.combination.FanInAction

Packages that use FanInAction

Package	Description
reactor.rx	Streams are reactive components derived from Reactive Extensions and implementing Reactive Streams specification.
reactor.rx.action.combination

Uses of FanInAction in reactor.rx

Methods in reactor.rx with parameters of type FanInAction

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.

Uses of FanInAction in reactor.rx.action.combination

Subclasses of FanInAction in reactor.rx.action.combination

Modifier and Type	Class and Description
class	CombineLatestAction<O,V,TUPLE extends Tuple>
class	MergeAction<O>
class	ZipAction<O,V,TUPLE extends Tuple>

Methods in reactor.rx.action.combination that return FanInAction

Modifier and Type	Method and Description
FanInAction<I,?,O,? extends FanInAction.InnerSubscriber<I,?,O>>	DynamicMergeAction.mergedStream()

Constructors in reactor.rx.action.combination with parameters of type FanInAction

Constructor and Description
DynamicMergeAction(FanInAction<I,?,O,? extends FanInAction.InnerSubscriber<I,?,O>> fanInAction)