取消 Observable 的执行 (RxJava 1)

Question

我已经创建了带有订阅的 Observable：

private Subscription mSearchSubscription = null;

mSearchSubscription = Observable.fromCallable(() -> {
    many network requests
}).subscribe(doing sth);

当我的活动被销毁时，我正在执行以下行：

 if (mSearchSubscription != null){
        mSearchSubscription.unsubscribe();
    }

根据在互联网上找到的信息，此行应取消此块中的所有代码执行。但它不是 :( 这个块内的所有网络请求都用订阅包装了 Observables，所以当一个请求完成时，下一个请求正在执行，依此类推。正如我注意到在执行取消订阅并且活动被破坏后 Observable 内的代码仍在执行。

有没有更好的方法来阻止它？我在这个项目中使用 RxJava1

更新： 我有 MVC 架构，控制器注入到 Activity 中。通过从活动中覆盖 onDestroy，我调用控制器中的方法来取消订阅。这是完整的代码。块 fromCallable(()-> ) 中的每个网络请求都类似于 mWebService.getSth(body parameters).subscribe(doSth) （在接口中返回 Observable ）。我不希望在执行内部 observable 期间停止，而是停止执行这段代码，就像 return 一样。这是因为许多请求需要一一执行并在一切准备就绪时将结果返回给活动。

Answer 1

你没有详细说明你如何以及为什么这样做，所以我最好的猜测建议是使用create：

Observable.create(emitter -> {
    CompositeSubscription resources = new CompositeSubscription();
    emitter.setSubscription(resources);

    if (resources.isUnsubscribed()) {
        return;
    }

    // add these if you want to cancel the inner sources
    // resources.add(

    mWebService.getFirst(/* params */).subscribe(/* postprocess */);

    // );

    if (resources.isUnsubscribed()) {
        return;
    }
    mWebService.getSecond(/* params */).subscribe(/* postprocess */);

    if (resources.isUnsubscribed()) {
        return;
    }

    mWebService.getThird(/* params */).subscribe(/* postprocess */);

    emitter.onNext(/* the result object*/
    emitter.onComplete();
}, Emitter.BackpressureMode.BUFFER)
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(/* work with the data */);