Channels
#rx
Title
m
mingkangpan
04/12/2017, 9:51 PMoaky, I got the issue, since rxbinding never calls onComplete,
groupbyt
thomasnield
04/12/2017, 10:10 PMmingkangpan: if its infinite you might want to consider using scan() instead of reduce(). It will emit each rolling accumulation and does not require onComplete()
m
mingkangpan
04/12/2017, 10:22 PMI wanted to try out the reduce since I want to get the sum of the 2 groups
p
Paul Woitaschek
04/13/2017, 4:36 AMIt does not need to be explicitly documented as its clear when you get a deeper understanding of rxjava
Just like toList. If it is not completed how can it tell when to emit?
But you can do the grouping before the first flatMap returns
Copy code
button.clicks()
.flatMap {
Observable.from(arrayListOf(1,2,3)).groupBy { … }...
}
}