RxJava入門之路(二)

收集一下可以避免背壓的運算符緩存

sample(500, TimeUnit.MILLISECONDS)  按期收集數據,併發送最後一個併發

throttleFirst(500,TimeUnit.MILLISECONDS)  按期收集數據,發送第一個數據spa

debounce(500,TimeUnit.MILLISECONDS)  若是在規定的間隔時間內沒有別的結果產生,則把這個結果提交給訂閱者處理,不然忽略該結果。it

Observable<List<Long>> ob= Observable.interval(100, TimeUnit.MILLISECONDS).buffer(300,TimeUnit.MILLISECONDS); 緩存過分產生的消息,生成集合class

 

http://www.jianshu.com/p/850af4f09b61List

相關文章
相關標籤/搜索