akarnokd / akarnokd/RxJavaExtensions
Add indexed transform operator to ParallelFlowable
- 主要言語
- Java
- スター
- 680
- フォーク
- 50
- 平均マージ
- 16分
- マージ済み PR(30日)
- 9
説明
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
コントリビューションガイド
このリポジトリのコントリビューションガイドは索引されていません
評価
この issue はまだ評価されていません。