close

用buffer搜集，再用fromIterable+reduce去阻塞每個Rx流做處理，之後用concatMap(flatMap)發射一次

Observable.range(1, 100)
.buffer(50)
.concatMap(int-> Observable.fromIterable(int).reduce((s, s2) -> s + s2).toObservable())
arrow
arrow
    全站熱搜
    創作者介紹
    創作者 JBLin 的頭像
    JBLin

    a0973378273的部落格

    JBLin 發表在 痞客邦 留言(0) 人氣()

    E-mail轉寄