首页 > 代码库 > RxJava入门之路（二）
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
RxJava入门之路（二）
声明：以上内容来自用户投稿及互联网公开渠道收集整理发布，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任，若内容有误或涉及侵权可进行投诉： 投诉/举报 工作人员会在5个工作日内联系你，一经查实，本站将立刻删除涉嫌侵权内容。