monix/monix

Revise Observable.mapParallelOrdered

Ouverte

#927 ouverte le 27 juin 2019

 (6 commentaires) (0 réaction) (0 personne assignée)Scala (244 forks)batch import
help wanted

Métriques du dépôt

Stars
 (1 934 étoiles)
Métriques de merge PR
 (Aucune PR mergée en 30 j)

Description

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

Guide contributeur