java - 如果发生超时异常，重新订阅可观察对象

Question

我正在使用改造来返回一个可观察的结果，作为对服务器的 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次时，它将重新订阅。

或者没有 lambda:

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){

        }