RxJavar用什么操作符可以使数据每隔一段时间取出一个

卌梓
  • 341

RxJavar用什么操作符可以使数据每隔一段时间取出一个

回复
阅读 2.9k
2 个回答
边城
  • 54.8k
✓ 已被采纳

懒得去搞 Java 的环境,给你个 JavaScript 的示例,你照着改成 Java 的吧

const Rx = require("rx");

Rx.Observable.range(0, 10)
    .map(n => 3 + n * 10)
    .concatMap((x, i) => {
        return Rx.Observable.interval(500)
            .take(1)
            .map(() => `${x}:${i}`);
    })
    .do(console.log)
    .subscribe();

补充一下

interval(500).take(1) 可以用 timer(500) 代替

使用 concatMap() 或者 map().concat()

clipboard.png]

private Object getData(int index) {
    //TODO 获取第n个数据
}


Observable.interval(1, TimeUnit.SECONDS)//每秒执行一次
          .flatMap(i->Observable.fromCallable(()->getData(i.intValue())))//获取数据
          .subscribe(s->System.out.println(s));//获取数据后的处理方法

如果获取对象的方法是快速执行的方法,flatMap也可以使用map来代替,改成

          .map(i->getData(i.intValue()))//获取数据
撰写回答
你尚未登录,登录后可以
  • 和开发者交流问题的细节
  • 关注并接收问题和回答的更新提醒
  • 参与内容的编辑和改进,让解决方法与时俱进
宣传栏