mingkangpan
04/12/2017, 9:33 PMbutton1.clicks()
.flatMap { arrayListOf(11,2,5,8,10,13,9,7,3,4).toObservable() }
.groupBy { i -> i % 2 }
.flatMapMaybe { g -> g.map { i -> i }.filter { i -> i % 3 != 0 }.reduce{ t1,t2 -> t1 + t2} }
.subscribe { s -> logCurrentThread("OnNext $s") }