### ResponseTransformer 和 ObservableTransformer 的实现与使用 在 RxJava 中，`ObservableTransformer` 是一个函数式接口，用于对 `Observable` 进行变换操作。它通常与 `compose` 方法结合使用，以减少重复代码并提高代码复用性。`ResponseTransformer` 则可以看作是一个具体的实现类，用于处理响应数据并提取需要的信息[^1]。 以下是一个完整的 `ResponseTransformer` 实现示例，以及如何通过 `ObservableTransformer` 来封装和简化代码： #### 1. ResponseTransformer 的定义 `ResponseTransformer` 可以被设计为一个工具类，专门用于处理 API 响应。假设我们有一个通用的响应结构 `ApiResponse<T>`，其中包含 `code`、`message` 和 `data` 字段。如果 `code == 200`，则表示请求成功，否则抛出异常。 ```java public class ApiResponse<T> { private int code; private String message; private T data; // Getter 和 Setter 方法 public int getCode() { return code; } public void setCode(int code) { this.code = code; } public String getMessage() { return message; } public void setMessage(String message) { this.message = message; } public T getData() { return data; } public void setData(T data) { this.data = data; } } ``` 接下来是 `ResponseTransformer` 的实现，该类将负责判断 `code` 是否为 `200` 并提取数据，或者抛出异常。 ```java import io.reactivex.Observable; import io.reactivex.ObservableTransformer; public class ResponseTransformer<T> implements ObservableTransformer<ApiResponse<T>, T> { @Override public Observable<T> apply(Observable<ApiResponse<T>> upstream) { return upstream.flatMap(response -> { if (response.getCode() == 200) { return Observable.just(response.getData()); } else { return Observable.error(new RuntimeException("Error: " + response.getMessage())); } }); } } ``` #### 2. 使用 ObservableTransformer 的示例 在实际使用中，可以通过 `compose` 方法将 `ResponseTransformer` 应用于任何 `Observable<ApiResponse<T>>`，从而避免重复代码。 ```java import io.reactivex.Observable; import io.reactivex.Observer; import io.reactivex.disposables.Disposable; public class Main { public static void main(String[] args) { Observable<ApiResponse<String>> observable = Observable.just( new ApiResponse<String>() {{ setCode(200); setData("Success Data"); }} ); observable.compose(new ResponseTransformer<>()) .subscribe(new Observer<String>() { @Override public void onSubscribe(Disposable d) { System.out.println("Subscribed"); } @Override public void onNext(String value) { System.out.println("Received: " + value); } @Override public void onError(Throwable e) { System.err.println("Error: " + e.getMessage()); } @Override public void onComplete() { System.out.println("Completed"); } }); } } ``` #### 3. 解释 - **ResponseTransformer**：实现了 `ObservableTransformer<ApiResponse<T>, T>` 接口，用于将 `ApiResponse<T>` 转换为 `T`，同时处理异常情况。 - **compose 方法**：通过 `compose` 方法将 `ResponseTransformer` 应用于 `Observable`，从而减少重复代码并提高可读性。 - **flatMap 操作符**：在 `ResponseTransformer` 内部使用了 `flatMap`，以便根据响应的 `code` 值决定是否返回数据或抛出异常。 --- ###