akarnokd / akarnokd/RxJavaExtensions

Add indexed transform operator to ParallelFlowable

Offen
#74 0 Kommentare 0 Reaktionen 0 zugewiesene Personen Auf GitHub ansehen
feature request
Vorherrschende Sprache
Java
Sterne
680
Forks
50
Ø Merge
16 Min.
Gemergte PRs (30 T.)
9

Beschreibung

Signature:

```java
ParallelTransformer transformRail(BiFunction, Integer, Publisher 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 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

Beitragsleitfaden

Für dieses Repository ist kein Beitragsleitfaden indexiert

Bewertung

Dieses Issue wurde noch nicht bewertet.

Neue Issues direkt in Ihr Postfach

Eine kurze Übersicht über anfängerfreundliche GitHub-Issues.