RxSwift 中的 Observable
是觀察者模式中被觀察到對(duì)象,相當(dāng)于一個(gè)事件序列狭园,會(huì)主動(dòng)向訂閱者發(fā)送新產(chǎn)生的事件信息读处。事件主要分為三類:
- .onNext(element) 表示新的事件數(shù)據(jù)。
- .onError(error) 表示事件序列因異常而完結(jié)
- .onCompleted() 表示事件序列完結(jié)妙啃。
Subscribe
如果一個(gè) Observable
被創(chuàng)建之后档泽,沒有個(gè)被任何的訂閱者訂閱的話,什么事情都不會(huì)發(fā)生揖赴。所以我們需要?jiǎng)?chuàng)建一個(gè)訂閱者馆匿,來響應(yīng)事件的觸發(fā)。
_ = Observable<String>.create { observerOfString in
print("Observable created")
observerOfString.on(.next("??"))
observerOfString.on(.completed)
return Disposables.create()
}
.subscribe { event in
print(event)
}
通過 subscribe
訂閱之后燥滑,會(huì)收到兩個(gè)消息 .onNext(element)
和 .onCompleted()
打印出:
??
completed