monix/monix

Revise Observable.mapParallelOrdered

Aperta

#927 aperta il 27 giu 2019

 (6 commenti) (0 reazioni) (0 assegnatari)Scala (244 fork)batch import
help wanted

Metriche repository

Star
 (1934 stelle)
Metriche merge PR
 (Nessuna PR mergiata in 30 g)

Descrizione

Implementation is quite complicated and perhaps could be improved.

I would like to see benchmark vs Observable.mapParallelUnordered and then if replacing java.ConcurrentQueue with the one from jctools (LowLevelQueue) has any performance benefit.

Ideally we could also simplify implementation but I don't have anything on my mind yet

Guida contributor