RxJava操做符observeOn的併發問題

RxJava操做符observeOn的併發問題 前幾天同事丟給我一段RxJava的代碼,代碼想要經過observeOn指定線程池來實現多線程消費,這個想法自己很美好。實際卻沒有發現多線程消費的現象,因此我決定好好研究一番,就以?的代碼開始吧!web long sleepTime = 300; long emitFrequency = 100; Observable.interval(emitFr
相關文章
相關標籤/搜索