These are chat archives for ReactiveX/RxJava

14th
Jun 2016
Darius Lapūnas
@DariusL
Jun 14 2016 07:44
Done
Abhinav Solan
@eyeced
Jun 14 2016 21:28
Is there a way in RxJava, that I can perform parallel processing on groups using groupBy and sequential processing on data within a group ?
Dorus
@Dorus
Jun 14 2016 21:29
source.groupBy().flatMap(e => e.map())?
or even source.groupBy().flatMap(e => e.concatMap())
Operators like map and concatMap will run sequential.
Abhinav Solan
@eyeced
Jun 14 2016 21:35
is flatMap by default parallel ?
concatMap(f) == flatMap(f, 1)
(maxConcurrent = 1)
Abhinav Solan
@eyeced
Jun 14 2016 21:46
Thanks a lot for the help @Dorus