RxJava và trang bị thêm - Tăng ngoại lệ tùy chỉnh tùy thuộc vào phản hồi của máy chủ

Question

Tôi muốn trang bị thêm để nâng cao ngoại lệ tùy chỉnh tùy thuộc vào phản hồi của máy chủ. Ví dụ trong cấu trúc sau:

{ 
"code":0, 
"message":"OK", 
"data":{....} 
} 

Tôi muốn nâng cao một ngoại lệ cho các thuê bao nếu code là bất cứ điều gì khác hơn là 0. Làm thế nào là nó có thể sử dụng Retrofit và Rx? Tôi rất thích viết logic này chỉ một lần và áp dụng cho tất cả các quan sát được trả lại bằng cách trang bị thêm.

Answer 1

Tôi muốn nêu ngoại lệ cho người đăng ký nếu mã là bất kỳ điều gì khác ngoài 0. Làm thế nào để sử dụng Retrofit và Rx?

Bạn có thể sử dụng một nhà điều hành Observable.flatMap:

api.request().flatMap(response -> { 
    if (response.getCode() != 0) { 
     return Observable.error(new Exception("Remote error occurred")); 
    } 

    return Observable.just(response); 
}); 

Tôi rất muốn viết logic này chỉ một lần và có nó áp dụng cho tất cả các quan sát được trả về bởi retrofit.

Thật không may, không có cách nào để thực hiện việc đó bằng cách sử dụng retrofit và rx-java. Bạn có để viết mã ở trên cho mỗi cuộc gọi retrofit. Điều duy nhất bạn có thể làm là sử dụng phương pháp Observable.compose và giảm số lượng bản mẫu mà bạn thực sự phải viết.

api.request().compose(new ResponseTransformer<Response>()); 

Và đây là lớp ResponseTransformer:

public static class ResponseTransformer<T extends Response> implements Observable.Transformer<T, T> { 
    @Override 
    public Observable<T> call(final Observable<T> observable) { 
     return observable.flatMap(response -> { 
      if (response.getCode() != 0) { 
       return Observable.error(new Exception("Remote error occurred")); 
      } 

      return Observable.just(response); 
     }); 
    } 
} 

CẬP NHẬT

Vâng, như tôi đã nói, không có cách nào để tránh mã boilerplate chỉ sử dụng retrofit và rxjava, nhưng bạn có thể giải quyết vấn đề này với dynamic proxies (lưu ý rằng bạn không cần phải gọi compose nữa):

final Api api = restAdapter.create(Api.class); 

final ClassLoader loader = api.getClass().getClassLoader(); 
final Class<?>[] interfaces = api.getClass().getInterfaces(); 

final Api proxy = (Api) Proxy.newProxyInstance(loader, interfaces, new ResponseInvocationHandler(api)); 

proxy.request().subscribe(response -> { 
    System.out.println("Success!"); 
}); 

ResponseInvocationHandler lớp:

public static class ResponseInvocationHandler implements InvocationHandler { 
    private final Object target; 

    public ResponseInvocationHandler(final Object target) { 
     this.target = target; 
    } 

    @Override 
    @SuppressWarnings({"unchecked"}) 
    public Object invoke(final Object proxy, final Method method, final Object[] args) throws Throwable { 
     final Object result = method.invoke(target, args); 

     if (result instanceof Observable) { 
      return Observable.class.cast(result).compose(new ResponseTransformer<>()); 
     } 

     return result; 
    } 
} 

Answer 2

tôi sẽ đề nghị một cách tiếp cận khác nhau.

Bạn sẽ cần phải triển khai ứng dụng khách OkHttp tùy chỉnh với Trình chặn đánh dấu tùy chỉnh.

 OkHttpClient client = new OkHttpClient(); 
     client.interceptors().add(new MyInterceptor()); 
     mAdapter = new RestAdapter.Builder().setEndpoint(Consts.ENDPOINT).setClient(new OkClient(client)) 
       .setLogLevel(RestAdapter.LogLevel.BASIC).build(); 

Trong trình chặn của bạn tùy thuộc vào mã được trả về, bạn có thể tiến hành bình thường hoặc ném ngoại lệ.

Something như thế này:

public class MyInterceptor implements Interceptor { 

    @Override 
    public Response intercept(Chain chain) throws IOException { 
     Response response = chain.proceed(chain.request()); 

     if(response.code() == 0) { 
      throw new RuntimeException("Something went wrong!"); 
     } 

     return response; 
    } 
} 

Answer 3

1 tùy chỉnh Observable.Operator:

public class YourOperator implements Observable.Operator{ 
    public void onNext(Data data){ 
     if (data.code != 0){ 
      //raise your custom Exception 
     } 
    } 
    public void onError(Throwable e){ 
     //handler Exception 
    } 
} 

2 người sử dụng như:

api.youRequest() 
    .lift(new YourOperator()) 
    .subscribe(....);