retrofit - 如何使用改造和 rxjava 取消任务

Question

我有休息api。

@Get("/serveraction")
public Observable<String> myRequest(@Query("Data") String data);

我知道，okhttp 具有取消功能(通过请求对象，通过标签)，但不知道如何将它与改造和 rxjava 一起使用。使用改造和rxjava实现网络任务取消机制的最佳方法是什么？

Answer 1

您可以使用标准的 RxJava2 取消机制 Disposable .

Observable<String> o = retrofit.getObservable(..);
Disposable d = o.subscribe(...);

// later when not needed
d.dispose();

Retrofit RxJava 调用适配器会将其重定向到 okHttp 的取消。

RxJava1: https://github.com/square/retrofit/blob/46dc939a0dfb470b3f52edc88552f6f7ebb49f42/retrofit-adapters/rxjava/src/main/java/retrofit2/adapter/rxjava/CallArbiter.java#L50-L53

RxJava2: https://github.com/square/retrofit/blob/46dc939a0dfb470b3f52edc88552f6f7ebb49f42/retrofit-adapters/rxjava2/src/main/java/retrofit2/adapter/rxjava2/CallEnqueueObservable.java#L92-L95