oaky, I got the issue, since rxbinding never calls...

# rx

[mingkangpan]

oaky, I got the issue, since rxbinding never calls onComplete, groupby can never work, fortunately I herad this in some presentation that groupby require onComple to get called by previous observables, but where is this documented?

[thomasnield]

mingkangpan: if its infinite you might want to consider using scan() instead of reduce(). It will emit each rolling accumulation and does not require onComplete()

[mingkangpan]

I wanted to try out the reduce since I want to get the sum of the 2 groups

[Paul Woitaschek]

It does not need to be explicitly documented as its clear when you get a deeper understanding of rxjava

[Paul Woitaschek]

Just like toList. If it is not completed how can it tell when to emit?

[Paul Woitaschek]

But you can do the grouping before the first flatMap returns

[Paul Woitaschek]

button.clicks()
  .flatMap {
 Observable.from(arrayListOf(1,2,3)).groupBy { … }...
  }
}