什么是RxSwift 3.0相当于RxSwift 2.x的AnonymousDisposable？

Question

所述ReactiveX.io文档使用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

要Observable在Swift 3中创建,你必须AnonymousDisposable用Disposables.create()这样的方式替换旧实例:

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

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

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

我希望这对你有帮助.