akarnokd / akarnokd/RxJavaExtensions

Add indexed transform operator to ParallelFlowable

Abierto
#74 0 comentarios 0 reacciones 0 asignados Ver en GitHub
feature request
Lenguaje dominante
Java
Estrellas
680
Forks
50
Merge medio
16 min
PR fusionados (30 d)
9

Descripción

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

Guía de contribución

No hay ninguna guía de contribución indexada para este repositorio

Evaluación

Este issue todavía no se ha evaluado.

Recibe los nuevos issues en tu correo

Un resumen breve de issues de GitHub para principiantes.