RxJava入门之路（二）

时间 2019-12-12

标签 rxjava 入门之路栏目 Java 繁體版

原文原文链接

收集一下可以避免背压的运算符缓存

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