如果发生超时异常，则重新订阅可观察项

Question

我使用retrofit将REST API调用的结果返回给服务器。通常会发生请求超时异常，并且observable停止执行。如何重新订阅重试，如果异常是一个特定类型的

myObservable 
    .subscribe(new Subscriber<Something> sub(){ 
     @override 
     void onNext(Something something){ 
      //do something with something 
     } 
        @override 
     void onError(Throwable e){ 
      //retry and resend call to server if e is request timeout exception 
     } 

Answer 1

可以使用retry运营商。

实施例：

myObservable 
    .retry((retryCount, throwable) -> retryCount < 3 && throwable instanceof SocketTimeoutException) 
    .subscribe(new Subscriber<Something> sub(){ 
     @override 
     void onNext(Something something){ 
      //do something with something 
     } 
        @override 
     void onError(Throwable e){ 

     } 

在该例子时，有一个最大SocketTimeoutException 3次，将重新订阅。

或不拉姆达：

myObservable 
    .retry(new Func2<Integer, Throwable, Boolean>() { 
       @Override 
       public Boolean call(Integer retryCount, Throwable throwable) { 
        return retryCount < 3 && throwable instanceof SocketTimeoutException; 
       } 
      }) 
    .subscribe(new Subscriber<Something> sub(){ 
     @override 
     void onNext(Something something){ 
      //do something with something 
     } 
        @override 
     void onError(Throwable e){ 

     }