(网上赌博新址) RxJavar用什么操作符可以使数据每隔一段时间取出一个
澳门新葡京官网
澳门新葡京官网
当前位置 : 澳门新葡京官网 > 网上赌博新址

(网上赌博新址) RxJavar用什么操作符可以使数据每隔一段时间取出一个

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

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

const Rx = require"rx";

Rx.Observable.range0, 10
    .mapn => 3 + n * 10
    .concatMapx, i => {
        return Rx.Observable.interval500
            .take1
            .map => `${x}:${i}`;
    }
    .doconsole.log
    .subscribe;

补充一下

interval500.take1 可以用 timer500 代替

使用 concatMap 或者 map.concat

]

private Object getDataint index {
    //TODO 获取第n个数据
}


Observable.interval1, TimeUnit.SECONDS//每秒执行一次
          .flatMapi->Observable.fromCallable->getDatai.intValue//获取数据
          .subscribes->System.out.printlns;//获取数据后的处理方法

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

          .mapi->getDatai.intValue//获取数据

栏目列表

广告位

澳门新葡京官网