Emtpy implementation for reactor.core.scala.publisher.ParallelFlux

[denyshorman]

I see some inconsistency between between reactor.core.publisher.ParallelFlux and reactor.core.scala.publisher.ParallelFlux. Scala ParallelFlux is empty.
Do you have plans to add some methods to this class ?
Thanks

[sinwe]

Hi,

Do you have plans to add some methods to this class ?

Yes, of course. I just don't have the use case yet. If you have the use case, I can add it.

[denyshorman]

Hi.
Ideal case for me would be to add all methods from Java ParallelFlux and add public method toJava (convert to Java ParallelFlux; currently I even can't convert it to java version because it is marked as private).
But if it is not possible, would be good to add common method: runOn, subscribe, map, filter, flatMap, concatMap, reduce, sequential.

[sinwe]

Thanks for your feedback.
I've released version 0.3.7 with a method to convert to Java for now so you can access its underlying ParallelFlux.
In the meantime, I'll update it with the common methods as you said.
If you could also gives me a list of methods that you used, that'll be a good use case for me.

[denyshorman]

Many thanks @sinwe !
I use runOn operator to specify scheduler, then filter to filter inputs, then map to run heavy computation, and then sequential to merge the results.

[sinwe]

Does it mean you don't care whether the end result is computed out of sequence than the input?

[denyshorman]

No, I need to use sequential in order to pass computed results to other operators like scan.