java - 如何在取消订阅时取消异步 Observable 线程

Question

如何取消取消订阅时的异步 Observable 线程？ 我有以下情况:

Observable.fromCallable(() -> api.UploadData(data))
.subscribeOn(Schedulers.from(threadExecutor))
.observeOn(AndroidSchedulers.mainThread())
.subscribe(subscriber);

取消订阅 Activity 销毁数据后，仍在其他线程上上传，我想取消上传操作。我怎样才能做到这一点？

Answer 1

您可以尝试doOnUnsubscribe并达到您的要求。

Observable.fromCallable(() -> api.UploadData(data))
   .subscribeOn(Schedulers.from(threadExecutor))
   .observeOn(AndroidSchedulers.mainThread())
   .doOnUnsubscribe(() -> api.StopUpload())
   .subscribe(subscriber);