RxJava入门之路（二）

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

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