How transform ParallelFlowable?

[deripas]

Hi!
I'm using version rxjava:2.2.19

Faced with the need to have its own context for each thread in parallel processing.
How to do this better?

Sintetic example on RxJava:

        ThreadLocal<Context> context = .... // Thread load context

        Flowable.fromPublisher(...)
                .parallel()
                .runOn(Schedulers.computation())
                .map(item -> transformWithContext(context.get(), item)) // <- map item with current context
                ...
                .sequential()

For example, in Reactor you can use the transformGroups method:

        Flux.from(...)
                .parallel()
                .transformGroups(groupedFlux -> {
                    Context ctx = new ....
                    return groupedFlux
                            .map(item -> transformWithContext(context.get(), item);
                })
                .sequential()

This approach is similar to using groupBy.
I couldn't find an analog to the transformGroupsmethod, or does it exist?

With best regards,
Anton

[akarnokd]

This type of operation is not supported in RxJava or any of the support libraries and there are no plans to add it.

[akarnokd]

All I can say is that it may happen in the near future as part of RxJavaExtensions: akarnokd/RxJavaExtensions#74