收集一下可以避免背壓的運算符緩存
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