create

通过一个构建函数完整的创建一个 Observable

create - 图1

create 操作符将创建一个 Observable,你需要提供一个构建函数,在构建函数里面描述事件(nexterrorcompleted)的产生过程。

通常情况下一个有限的序列,只会调用一次观察者onCompleted 或者 onError 方法。并且在调用它们后,不会再去调用观察者的其他方法。


演示

创建一个 [0, 1, ... 8, 9] 的序列:

  1. let id = Observable<Int>.create { observer in
  2. observer.onNext(0)
  3. observer.onNext(1)
  4. observer.onNext(2)
  5. observer.onNext(3)
  6. observer.onNext(4)
  7. observer.onNext(5)
  8. observer.onNext(6)
  9. observer.onNext(7)
  10. observer.onNext(8)
  11. observer.onNext(9)
  12. observer.onCompleted()
  13. return Disposables.create()
  14. }