swift – 如何取消订阅观察？

func foo() -> Observable<Foo> {
    return Observable.create { observer in
      // ...
    }
  }

  func bar() {
    foo().observeOn(MainScheduler.instance)
      .subscribeNext {
        // ...
      }
      .addDisposableTo(disposeBag)
  }

如果我想稍后在bar中观察unsubscribe,我该怎么做？

更新

我知道我可以打电话处理,但根据RxSwift docs：

Note that you usually do not want to manually call dispose; this is only educational example. Calling dispose manually is usually a bad code smell.

那么取消订阅只是没有实施？我已经完成了对RxSwift代码的探索,并且在我能够理解正在发生什么的程度上,它看起来不像从订阅方法返回的Disposable是任何具有有用功能的东西(除了处理).

disposeBag = nil

你班上的某个地方.

问题编辑后：您希望有选择地取消订阅某些Observable,可能是在满足某些条件时.您可以使用另一个表示这些条件的Observable,并根据需要使用takeUntil运算符取消订阅.

//given that cancellingObservable sends `next` value when the subscription to `foo` is no longer needed

foo().observeOn(MainScheduler.instance)
  .takeUntil(cancellingObservable)
  .subscribeNext {
    // ...
  }
  .addDisposableTo(disposeBag)