Maison > Questions et réponses > le corps du texte
RxJavar用什么操作符可以使数据每隔一段时间取出一个
大家讲道理2017-04-17 17:54:23
Je suis trop paresseux pour travailler sur l'environnement Java, je vais donc vous donner un exemple JavaScript. Vous pouvez le suivre et le changer en 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();
Juste quelque chose à ajouter
interval(500).take(1)
peut être remplacé par timer(500)
ou concatMap()
map().concat()
]
天蓬老师2017-04-17 17:54:23
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));//获取数据后的处理方法
Si la méthode d'obtention de l'objet est une méthode d'exécution rapide, flatMap peut également être remplacé par map et changé en
.map(i->getData(i.intValue()))//获取数据