如何使用 RxJava 取消 Retrofit 中的单个网络请求？

Question

我正在使用 retrofit 和 rxjava 从网络上下载一些文件。在我的应用程序中，用户可以取消下载。

伪代码：

   Subscription subscription = Observable.from(urls)
            .concatMap(this::downloadFile)
            .subscribe(file -> addFileToUI(file), Throwable::printStackTrace);

现在，如果我取消订阅，所有请求都会被取消。我想一个一个下载，所以才用了concatMap。如何取消特定请求？

Answer 1

有一种机制可以通过外部刺激取消个人流量：takeUntil。不过，您必须为其使用一些外部跟踪：

ConcurrentHashMap<String, PublishSubject<Void>> map =
     new ConcurrentHashMap<>();


Observable.from(urls)
.concatMap(url -> {
    PublishSubject<Void> subject = PublishSubject.create();
    if (map.putIfAbsent(url, subject) == null) {
        return downloadFile(url)
            .takeUntil(subject)
            .doAfterTerminate(() -> map.remove(url))
            .doOnUnsubscribe(() -> map.remove(url));
    }
    return Observable.empty();
})
.subscribe(file -> addFileToUI(file), Throwable::printStackTrace);

// sometime later

PublishSubject<Void> ps = map.putIfAbsent("someurl", PublishSubject.create());
ps.onCompleted();

如何使用 RxJava 取消 Retrofit 中的单个网络请求？

How to cancel individual network request in Retrofit with RxJava?

java

android

rx-java

retrofit

rx-android