收集一下能够避免背压的运算符

sample(500, TimeUnit.MILLISECONDS)  定期收集数据,并发送最后一个

throttleFirst(500,TimeUnit.MILLISECONDS)  定期收集数据,发送第一个数据

debounce(500,TimeUnit.MILLISECONDS)  如果在规定的间隔时间内没有别的结果产生,则把这个结果提交给订阅者处理,否则忽略该结果。

Observable<List<Long>> ob= Observable.interval(100, TimeUnit.MILLISECONDS).buffer(300,TimeUnit.MILLISECONDS); 缓存过度产生的消息,生成集合

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

05-13 01:06