RxSwift 中的 Observable
是观察者模式中被观察到对象,相当于一个事件序列,会主动向订阅者发送新产生的事件信息。事件主要分为三类:
- .onNext(element) 表示新的事件数据。
- .onError(error) 表示事件序列因异常而完结
- .onCompleted() 表示事件序列完结。
Subscribe
如果一个 Observable
被创建之后,没有个被任何的订阅者订阅的话,什么事情都不会发生。所以我们需要创建一个订阅者,来响应事件的触发。
_ = Observable<String>.create { observerOfString in
print("Observable created")
observerOfString.on(.next("😄"))
observerOfString.on(.completed)
return Disposables.create()
}
.subscribe { event in
print(event)
}
通过 subscribe
订阅之后,会收到两个消息 .onNext(element)
和 .onCompleted()
打印出:
😄
completed