swift - 什么是 RxSwift 3.0 等同于 RxSwift 2.x 的 AnonymousDisposable？

Question

ReactiveX.io documentation使用 AnonymousDisposable，它在 RxSwift 2.x 中，但在 RxSwift 3.0 中是一个未解析的标识符。我应该改用什么？

let source = Observable.create { observer in
  for i in 1...5 {
    observer.on(.Next(i))
  }
  observer.on(.Completed)

  // Note that this is optional. If you require no cleanup you can return
  // NopDisposable.instance
  return AnonymousDisposable {
    print("Disposed")
  }
}

source.subscribe {
  print($0)
}

Answer 1

要在 Swift 3、4、5 中创建 Observable，您必须用 Disposables.create() 替换旧的 AnonymousDisposable 实例，像这样:

let source = Observable.create { observer in
    observer.on(.next(1))
    observer.on(.completed)
    return Disposables.create()
}

如果你想在处理 Observable 时采取一些行动，你可以使用你之前提到的那个:

return Disposables.create {
    print("Disposed")      
}

希望对你有帮助