RxJava 将一组数据每隔一定时间发送出来

data = [0,1,2,3.....]delay(time)   delay(time)    delay(time)0 -----------> 1 -----------> 2 -----------> 3 ...
复制代码

使用doOnNext() + sleep(2000)

  Flowable.fromIterable(this.mock.messages).doOnNext(message -> SystemClock.sleep(2000)).subscribe(message -> Timber.d("message.content = %s", message.content));
复制代码

使用Zip操作符

Observable<Message> listObservable = Observable.fromIterable(mock.messages);
Observable<Long> timeObservable = Observable.interval(300, TimeUnit.MILLISECONDS);
Observable<String> zip =Observable.zip(listObservable, timeObservable, (message, aLong) -> message.content);zip.doOnComplete(() -> Timber.d("complete")).subscribe(s -> Timber.d("s = %s", s));
复制代码

转载于:https://juejin.im/post/5a62c9cd6fb9a01cbe656838

RxJava 将一组数据每隔一定时间发送出来相关推荐

怎么计算一组数据的波动_数据分析(一)：数据描述统计
一. 数据描述统计看了一个纪录片 - The Joy Of Stats <统计的乐趣>,这虽然是一个关于数据统计分析的纪录短片,但短片中对于数据统计在实际应用场景中应用的效果还是很值得思 ...
90年代中国人一个月挣多少钱？一组数据带你看懂90年代消费情况
转载/挖数最近几天,无意中在网上找到这本1999年的旧杂志里边以杭州作为城市样本,调研了90年代杭州市的家庭收入及支出,读着读着我仿佛走进岁月时光机,穿越回23年前,以下摘取部分数据. 以1995 ...
LabVIEW采集NI 9205多个通道数据，为什么切换时间比预想的长
LabVIEW采集NI 9205多个通道数据,为什么切换时间比预想的长基于CompactRIO的数据采集系统,在上面使用NI 9205模块配合FPGA节点编程来进行模拟电平的采集.当仅仅使用单通道进 ...
FPGA串口收发（四）：接收数据并转发，间隔时间发送
FPGA串口收发(四):接收数据并转发,间隔时间发送 // Description: 串口收发:串口接收数据,内部生成数据,串口间隔特定时间发送数据 // 串口接收数据:串行信号线 1101_1000 ...
商业贷款和公积金贷款差多少？一组数据告诉你！
商业贷款和公积金贷款差多少?一组数据告诉你! 2017-07-13 18:06 说到房贷,自然会想到商业贷款和公积金贷款这两种贷款方式,这两种方式有很多的区别,比较明显的就是贷款利率,这也是很多人会选 ...
c语言峰值算法_C语言寻找一组数据中的第一第二峰值
C语言寻找一组数据中的第一第二峰值实验要求,我需要找出一组数组中的两个峰值:第一个峰值和第二个峰值及其数组下标.这组数据画出的图应该是这样的,我就要找出图中的那两个峰值我写的程序如下,我试了一下, ...
《Excel 职场手册：260招菜鸟变达人》一第 14 招　利用数据验证记录数据录入时间...
本节书摘来异步社区<Excel 职场手册:260招菜鸟变达人>一书中的第1章,第14节,作者: 聂春霞 , 佛山小老鼠责编: 王峰松,更多章节内容可以访问云栖社区"异步社区&q ...
mysql 当前时间减指定时间_MySQL实现当前数据表的所有时间都增加或减少指定的时间间隔(推荐)...
DATE_ADD() 函数向日期添加指定的时间间隔. 当前表所有数据都往后增加一天时间: UPDATE ACT_BlockNum SET CreateTime = DATE_ADD(CreateTim ...
matlab字母随机排列,matlab_一组数据元素随机排列
如何生成一组数据元素随机排列[随机打乱顺序,产生新的排列] 1. 使用的matlab函数: randperm() 1)语法格式:R = randperm(n) 2)函数功能:将数字1:n进行随机排列, ...

RxJava 将一组数据每隔一定时间发送出来

使用doOnNext() + sleep(2000)

使用Zip操作符

RxJava 将一组数据每隔一定时间发送出来相关推荐

最新文章

热门文章