重试时修改源 Observable - RxJava [英] Modify Source Observable on retry - RxJava

问题描述

如何在重试时更新源可观察对象?

How do i update a source observable on retry?

List<String> ids = new ArrayList<>(); // A,B,C
Observable.from(ids)
          .retryWhen(errors -> {
                    return errors
                    .zipWith(Observable.range(0, 1), (n, i) -> i)
                    .flatMap(retryCount -> Observable.timer((long) Math.pow(2, retryCount), TimeUnit.MINUTES));

           })
           .subscribe(....);

如果我想传递一些其他值，现在而不是将//A,B,C 作为 ids 传递.我该怎么做?或者这是否是正确的方法?

now rather than passing //A,B,C as ids if i want to pass some other values. How do i do it? or is this even the right approach?

推荐答案

使用 defer.这将允许重新计算 ids:

Use defer. This would allow ids to be re-computed:

Observable.defer(() -> {
    List<String> ids = // compute this somehow
    return Observable.from(ids);
}).retryWhen(...

关于延迟运算符的文档

这篇关于重试时修改源 Observable - RxJava的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！