RxJava 如何在链平面图中重试部分

Question

Observable.just()
    .flatMap()
    .flatMap()
  <-Back to This line-----|
    .flatMap()            |
    .flatMap()            |
                          |
    .flatMap()            |
    .flatMap()            |             
    ------------------->Error Occur
    .flatMap()
    .flatMap()

我有一个 flatMap 链，在一个 flatMap 中，当它发出错误时，我想返回到 flatMap 链的一部分，我尝试使用缓存和重试运算符，但它不能被停止处置（）

Answer 1

你必须把它们变成内流，例如：

Observable.just()
    .flatMap()
    .flatMap(v -> 
        Observable.just(v)
        .flatMap()            
        .flatMap()            
                          
        .flatMap()            
        .flatMap()                         
        .retry()
    )
    .flatMap()
    .flatMap()

RxJava 如何在链平面图中重试部分

RxJava How to retry partial in chain flatmap

rx-java2