RxJava retryKhi đăng ký lại tuyên truyền

Question

Tôi đang sử dụng Retrofit với RxJava trong ứng dụng Android để liên lạc và phải xử lý lỗi khi phân tích phản hồi từ phản hồi HTTP có vẻ ok (mã trạng thái 200).

Tôi cũng đã triển khai cách xử lý lỗi bằng cách sử dụng toán tử retryWhen được kết nối với đầu vào của người dùng để quyết định có nên thử lại hay không. Điều này hoạt động bằng cách đăng ký lại bản gốc Observable.

Cách tiếp cận đầu tiên tôi đã cố gắng là có một cái gì đó như thế này:

services.getSomething() 
    .map(response -> { 
    if (checkBadResponse(response)) { 
     throw new RuntimeException("Error on service"); 
    } else { 
     return parseResponse(response); 
    } 
    }).retryWhen(this::shouldRetry); 

Với dịch vụ không được gọi một lần nữa. Có vẻ như nhà điều hành retryWhen không thể đăng ký lại với dịch vụ Observable của dịch vụ.

gì kết thúc làm việc đã được thực hiện một hành mà không gửi onCompleted về phía trước và sử dụng nó với lift như sau:

public class CheckResponseStatus<T> implements Observable.Operator<ResponsePayload<T>, ResponsePayload<T>> { 
    @Override 
    public Subscriber<? super ResponsePayload<T>> call(Subscriber<? super ResponsePayload<T>> subscriber) { 
     return new Subscriber<ResponsePayload<T>>() { 
      private boolean hasError = false; 

      @Override 
      public void onCompleted() { 
       if (!hasError) 
        subscriber.onCompleted(); 
      } 

      @Override 
      public void onError(Throwable e) { 
       hasError = true; 
       subscriber.onError(e); 
      } 

      @Override 
      public void onNext(ResponsePayload<T> response) { 
       if (response.isOk()) { 
        subscriber.onNext(response); 
       } else { 
        hasError = true; 
        subscriber.onError(new RuntimeException(response.getMessage())); 
       } 
      } 
     }; 
    } 
} 

Sử dụng nó như:

services.getSomething() 
    .lift(new CheckResponseStatus()) 
    .map(response -> parseResponse(response)) 
    .retryWhen(this::shouldRetry); 

Là này đúng cách để đối phó với nó hoặc là có một cách đơn giản hơn, tốt hơn?

Answer 1

Dường như lỗi trong việc triển khai rx-java. Dù sao, việc ném một ngoại lệ từ hàm map là một điều xấu vì hàm này được cho là thuần túy (ví dụ như không có tác dụng phụ). Bạn nên sử dụng một nhà điều hành flatMap trong trường hợp của bạn:

services.getSomething() 
    .flatMap(response -> { 
    if (checkBadResponse(response)) { 
     return Observable.<ResponseType>error(new RuntimeException("Error on service")); 
    } else { 
     return Observable.<ResponseType>just(parseResponse(response); 
    } 
    }).retryWhen(this::shouldRetry); 

Đoạn mã trên làm việc như mong đợi và thực sự lại yêu cầu nếu lỗi xảy ra.