Skip to content

Add indexed transform operator to ParallelFlowable #74

Open
@akarnokd

Description

@akarnokd

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 Flowables 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 input Flowable for a time or at all.
    • the input Flowable may terminate before the downstream gets to subscribing to it.

See also https://github.com/akarnokd/RxJavaMicroprofileRS/blob/master/src/main/java/hu/akarnokd/rxjava3/mprs/DeferredProcessor.java

Metadata

Metadata

Assignees

No one assigned

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions