Изменить источник, наблюдаемый при повторной попытке - RxJava

Question

Как обновить источник, наблюдаемый при повторном запуске?

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 как идентификаторы, если я хочу передать некоторые другие значения. Как мне это сделать? или это даже правильный подход?

Answer 1

Использование defer. Это позволит ids быть повторно вычислено:

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

Documentation on the defer operator

Answer 2

onErrorResumeNext могут быть использованы. Вероятно, вам нужна дополнительная логика для соответствия вашему варианту использования. Документация для операторов обработки ошибок here.

List<String> ids = new ArrayList<>(); // A,B,C 
List<String> ids2 = new ArrayList<>(); // D,E,F 
Observable.from(ids) 
     .onErrorResumeNext(throwable -> { 
      return Observable.from(ids2); 
     });