根据服务器响应重复 Retrofit2.0 api-call

Question

使用 Retrofit2（版本：2.3.0）、OkHTTP3（版本：3.9.0）和 RxJava2（版本：2.0.0）

rest api 调用场景

 Observable<ServerResponse> backendService.isUserVerified("someuserName") 

返回 200 Ok HTTP

如果用户被验证，预期的成功响应 JSON POJO

{

  user: "someUserName",

  isVerified: "yes"

}

如果用户未通过验证，则预期的成功响应 JSON POJO

{

  user: "someUserName",

  isVerified: "no"

}

以下是我正在尝试实现的代码

 backendService.isUserVerified("someuserName")
 .subscribeOn(Schedulers.io())
 .observeOn(AndroidSchedulers.mainThread())

  //Want to add a flatmap (or some other operator)
  .flatmap(new Function<ServerResponse>, ObservableSource<?>>(){
            @Override
            public ObservableSource<?> apply(ServerResponse serverResponse) throws Exception {
                if(0 != serverResponse.getisVerified.compareToIgnoreCase("yes")) {
                return Observable.error(new CustomException());
             }
             return //current observable.
  }

 .retryWhen(mRetryHandler)
 .subscribeWith(observer);

目的是在验证 == no 时抛出自定义异常，以便 retryWhen() 操作员可以参与重复调用链，否则希望通过链继续直到 subscribe()。

任何指针/帮助？

Answer 1

您可以只使用doOnNext 而不是flatmap：

backendService.isUserVerified("someuserName")
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())

//we can throw an exception if the user is not verified or keep the response as it is otherwise
.doOnNext(serverResponse -> {
                        if(0 != serverResponse.getisVerified.compareToIgnoreCase("yes")) 
                        {
                            throw new CustomException();
                        }
                    })

.retryWhen(mRetryHandler)
.subscribeWith(observer);

doOnNext 操作符只是对发射的项目执行一个函数而不改变它。您只想根据项目在特定情况下抛出错误，否则不要更改它，因此它是一个合适的运算符。由于您不会在 doOnNext 运算符之前或之后更改线程，因此在使用下一个运算符中的项目之前，您知道它将在继续之前抛出异常，以防它应该抛出它。

这是运营商链接文档中的一个示例：

Observable.just(1, 2, 3)
      .doOnNext(new Action1<Integer>() {
      @Override
      public void call(Integer item) {
        if( item > 1 ) {
          throw new RuntimeException( "Item exceeds maximum value" );
        }
      }
    }).subscribe(new Subscriber<Integer>() {
    @Override
    public void onNext(Integer item) {
        System.out.println("Next: " + item);
    }
    @Override
    public void onError(Throwable error) {
        System.err.println("Error: " + error.getMessage());
    }
    @Override
    public void onCompleted() {
        System.out.println("Sequence complete.");
    }
});

[输出：]

下一个：1

错误：项目超过最大值

Answer 2

如果你想使用Observable.error(new CustomException()); 抛出一个错误，你不需要为错误返回一个特定的对象和另一个返回预期答案的函数，这是一个异常，将转到onError() 方法.您的ObservableResource<?> 必须返回您在onResponse() 方法中从Subscriber 检索到的预期答案。如果您使用Observable.error() 抛出错误，您的链将被破坏，错误将转到onError()。

编辑

你应该使用retry函数，因为它会返回ServerResponse，你可以检查它是否有效。使用retryWhen，您只会在出现问题时收到错误消息。在你的情况下，你没有得到任何错误，你得到了答案。在这种情况下，您不需要 flatMap

.retry(new BiPredicate<ServerResponse, Throwable>() {
           @Override
           public boolean test(ServerResponse serverResponse, Throwable throwable) throws Exception {
               return serverResponse.getisVerified.equals("no");
           }
     })