Open
Description
Signature:
ParallelTransformer<T, R> transformRail(BiFunction<Flowable<T>, Integer, Publisher<R> mapper)
Given the parallelism of the ParallelFlowable
, the function will be called for each rail indexed 0..n-1 to provide a mapping for that particular rail.
Considerations:
- The input
Flowable
s will be single-subscriber only. - The implementation should not buffer but has to be careful when relaying signals because:
- the returned
Publisher
may not be connected to the inputFlowable
for a time or at all. - the input
Flowable
may terminate before the downstream gets to subscribing to it.
- the returned