問題描述

RxJavar用什么操作符可以使數(shù)據(jù)每隔一段時間取出一個

問題解答

懶得去搞 Java 的環(huán)境，給你個 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()

]

private Object getData(int index) { //TODO 獲取第n個數(shù)據(jù)}Observable.interval(1, TimeUnit.SECONDS)//每秒執(zhí)行一次 .flatMap(i->Observable.fromCallable(()->getData(i.intValue())))//獲取數(shù)據(jù) .subscribe(s->System.out.println(s));//獲取數(shù)據(jù)后的處理方法

如果獲取對象的方法是快速執(zhí)行的方法,flatMap也可以使用map來代替，改成

.map(i->getData(i.intValue()))//獲取數(shù)據(jù)