RxSwfit 學習筆記（二）Observable & Observer
上一篇文章中，咱們已經簡單瞭解了一下RxSwift入門的第一步，在RxCocoa的幫助下，來實現一個登陸輸入監聽校驗的功能。 那麼咱們要如何建立一個屬於咱們本身的監聽序列呢？或者說如何監聽咱們本身建立的屬性呢，好比說一個String。swift
咱們這裏先簡單說一下Observable與Observer的區別與聯繫bash
**Observable：**可監聽序列，從名字上來看，咱們就能理解，他是用來被監聽的，而不是主動監聽的閉包
Observer：觀察者，顯而易見，它與「可監聽序列」相對，它就是用來監聽序列的角色。監聽事件，而後它須要這個事件作出響應。例如：監聽到一個
onNext事件，而後咱們對這個事件做出響應。框架兩者相互配合，從而達到響應的效果。異步
Observable 可監聽序列
介紹內容摘取自RxSwift的使用詳解3（Observable介紹、建立可觀察序列） Observable 做爲 Rx 的根基，咱們首先對它要有一些基本的瞭解。 ###1. Observableide
Observable<T>這個類就是Rx框架的基礎，咱們能夠稱它爲可觀察序列。它的做用就是能夠異步地產生一系列的Event（事件），即一個Observable<T>對象會隨着時間推移不按期地發出event(element : T)這樣一個東西。- 並且這些
Event還能夠攜帶數據，它的泛型<T>就是用來指定這個Event攜帶的數據的類型。 - 有了可觀察序列，咱們還須要有一個
Observer（訂閱者）來訂閱它，這樣這個訂閱者才能收到Observable<T>不時發出的Event。
2.Event
查看 RxSwift 源碼能夠發現，事件 Event 的定義以下：學習
public enum Event<Element> {
/// Next element is produced.
case next(Element)
/// Sequence terminated with an error.
case error(Swift.Error)
/// Sequence completed successfully.
case completed
}
複製代碼
能夠看到 Event 就是一個枚舉，也就是說一個 Observable 是能夠發出 3 種不一樣類型的 Event 事件：測試
-
next：
next事件就是那個能夠攜帶數據<T>的事件，能夠說它就是一個「最正常」的事件。ui -
error：
error事件表示一個錯誤，它能夠攜帶具體的錯誤內容，一旦Observable發出了error event，則這個Observable就等於終止了，之後它不再會發出event事件了。this -
completed：
completed事件表示Observable發出的事件正常地結束了，跟error同樣，一旦Observable發出了completed event，則這個Observable就等於終止了，之後它不再會發出event事件了。
Observer 觀察者
在上文咱們已經有提到過了Observer就是用來「觀察」Observable的，那麼是如何觀察的呢？ 咱們使用 subscribe() 方法來訂閱（觀察）Observable。 上面有提到Observable發出三種事件next、error、completed，那麼Observer也對應的能監聽到這三種事件
//訂閱序列
observable.subscribe(onNext: { (str) in
print(str)
}, onError: { (error) in
print(error)
}, onCompleted: {
print("completed")
}).disposed(by: disposebag)
複製代碼
Observable & Observer 配合使用
1. 最普通的序列建立與訂閱
enum MyError: Error {
case errorA
case errorB
}
//建立序列
let testOB = Observable<String>.create { ob in
//發送next事件
ob.onNext("test1")
ob.onNext("test2")
ob.onNext("test3")
//發送error事件
ob.onError(MyError.errorA)
//發送completed事件
ob.onCompleted()
return Disposables.create()
}
//訂閱序列
testOB.subscribe(onNext: { (str) in
print(str)
}, onError: { (error) in
print(error)
}, onCompleted: {
print("completed")
}).disposed(by: disposebag)
複製代碼
打印結果：
test1
test2
test3
errorA
複製代碼
細心的朋友已經發現了，咱們明明有發送completed，可是爲何沒有打印出來，很明顯，問題在ob.onError()上。 咱們在測試一下，挪動一下ob.onError()的位置
//建立序列
let testOB = Observable<String>.create { ob in
ob.onNext("test1")
ob.onNext("test2")
ob.onError(MyError.errorA)
ob.onNext("test3")
ob.onCompleted()
return Disposables.create()
}
複製代碼
打印結果：
test1
test2
errorA
複製代碼
因此咱們能得出結論，一旦觀察者有監聽到error事件，那麼就會在觸發onError:閉包結束後，中止監聽。後續應該會好好聊聊這個問題。咱們先暫且瞭解就好。
2. 跨類使用
咱們新建立一個類FirstViewModel，聲明一個Observable<String>類型的變量，而後在初始化方法中直接建立出來。
class FirstViewModel {
var text : Observable<String>!
let disposeBag = DisposeBag()
init() {
text = Observable.create { (observer) -> Disposable in
observer.onNext("test1")
observer.onNext("test2")
observer.onNext("test3")
observer.onCompleted()
return Disposables.create()
}
}
}
複製代碼
而後咱們在控制器中，初始化FirstViewModel
class FirstViewController: UIViewController {
var disposeBag = DisposeBag()
override func viewDidLoad() {
super.viewDidLoad()
let vm : FirstViewModel = FirstViewModel.init()
vm.text.subscribe(onNext: { obString in
print(obString)
}, onCompleted: {
print("completed")
}).disposed(by: disposeBag)
}
}
複製代碼
command + R 看 輸出結果
msg1
msg2
msg3
completed
複製代碼
3. 點擊按鈕發送事件
class FirstViewModel {
class func getText() -> Observable<String> {
//建立一個just事件
return .just("你收到了嘛")
}
}
複製代碼
btn.rx.tap.subscribe(onNext: { [weak self] in
self?.btnClick()
}).disposed(by: disposeBag)
//事件
func btnClick() -> Void{
FirstViewModel.getText().subscribe(onNext: { (String) in
print(String)//輸出結果： 你收到了嘛
}).disposed(by: disposeBag)
}
複製代碼
這裏出現了一個.just，這是什麼呢。 建立Observable序列的方法有不少種。
建立Observable 序列其餘方法
各個方法的區別於做用，能夠看這裏
print("----------- this is just ----------- ")
let observable_just = Observable<Int>.just(5)
observable_just.subscribe(onNext: { (Int) in
print("\(Int)")
}, onCompleted: {
print("just completed")
}).disposed(by: disposeBag)
print("----------- this is of ----------- ")
let observable_of = Observable.of("A", "B", "C")
observable_of.subscribe(onNext: { (String) in
print("\(String)")
}, onCompleted: {
print("of completed")
}).disposed(by: disposeBag)
print("----------- this is from ----------- ")
let observable_from = Observable.from(["A", "B", "C"])
observable_from.subscribe(onNext: { (String) in
print("\(String)")
}, onCompleted: {
print("from completed")
}).disposed(by: disposeBag)
print("----------- this is empty ----------- ")
let observable_empty = Observable<Int>.empty()
observable_empty.subscribe(onNext: { (Int) in
print("this is empty")
}, onCompleted: {
print("empty completed")
}).disposed(by: disposeBag)
print("----------- this is never ----------- ")
let observable_nerver = Observable<Int>.never()
observable_nerver.subscribe(onNext: { (Int) in
print("this is never")
}, onCompleted: {
print("never completed")
}).disposed(by: disposeBag)
print("----------- this is error ----------- ")
enum MyError: Error {
case A
case B
}
let observable_error = Observable<Int>.error(MyError.A)
observable_error.subscribe(onNext: { (Int) in
}, onError: { (Error) in
print(" \(Error)")
}, onCompleted: {
print("error completed")
}).disposed(by: disposeBag)
print("----------- this is range ----------- ")
let observable_range = Observable.range(start: 1, count: 5)
observable_range.subscribe(onNext: { (Int) in
print("\(Int)")
}, onCompleted: {
print("range completed")
}).disposed(by: disposeBag)
//不能放在主線程，會堵塞
// let observable_repeat = Observable.repeatElement(1)
// observable_repeat.subscribe(onNext: { (Int) in
// print("this is repeat -- \(Int)")
// }, onCompleted: {
// print("repeat completed")
// }).disposed(by: disposeBag)
print("----------- this is generate ----------- ")
//使用generate()方法
let observable_generate = Observable.generate(
initialState: 0,
condition: { $0 <= 10 },
iterate: { $0 + 2 }
)
observable_generate.subscribe(onNext: { (Int) in
print("\(Int)")
}, onCompleted: {
print("generate completed")
}).disposed(by: disposeBag)
print("----------- this is deferred ----------- ")
//用於標記是奇數、仍是偶數
var isOdd = true
//使用deferred()方法延遲Observable序列的初始化，經過傳入的block來實現Observable序列的初始化而且返回。
let factory : Observable<Int> = Observable.deferred {
//讓每次執行這個block時候都會讓奇、偶數進行交替
isOdd = !isOdd
//根據isOdd參數，決定建立並返回的是奇數Observable、仍是偶數Observable
if isOdd {
return Observable.of(1, 3, 5 ,7)
}else {
return Observable.of(2, 4, 6, 8)
}
}
//第1次訂閱測試
factory.subscribe { event in
print("\(isOdd)", event)
}.disposed(by: disposeBag)
//第2次訂閱測試
factory.subscribe { event in
print("\(isOdd)", event)
}.disposed(by: disposeBag)
//第3次訂閱測試
factory.subscribe { event in
print("\(isOdd)", event)
}.disposed(by: disposeBag)
//RxSwift 5.x 棄用 TimeInterval，改用 DispatchTimeInterval
print("----------- this is interval ----------- ")
let observable_interval = Observable<Int>.interval(.seconds(1), scheduler: MainScheduler.instance)
observable_interval.subscribe { event in
print(event)
}.disposed(by: disposeBag)
print("----------- this is timer ----------- ")
//5秒種後發出惟一的一個元素0
let observable_timer = Observable<Int>.timer(.seconds(5), scheduler: MainScheduler.instance)
observable_timer.subscribe { event in
print(event)
}.disposed(by: disposeBag)
//延時5秒種後，每隔1秒鐘發出一個元素
let observable_timer2 = Observable<Int>.timer(.seconds(5), period: .seconds(5), scheduler: MainScheduler.instance)
observable_timer2.subscribe { event in
print(event)
}.disposed(by: disposeBag)
複製代碼
既是Observable 又是 Observer
怎麼說呢，像TextField，咱們既能夠監聽它，又能夠把它當作一個觀察者。
- 若是是初學者，那麼以爲上面這句話很奇怪，這個做爲觀察者是什麼意思？ 咱們能夠這麼理解，咱們既能夠監聽文本框的輸入，又能夠給文本框賦值。
那麼接下來我就爲大家介紹一下這種狀況。
class FifthViewController: UIViewController {
var textF:UITextField!
let disposeBag = DisposeBag()
override func viewDidLoad() {
super.viewDidLoad()
textF = UITextField.init(frame: .init(x: 20, y: 120, width: view.frame.width, height: 40))
textF.borderStyle = .roundedRect
view.addSubview(textF)
//把文本框當作觀察者
let observer = textF.rx.text
let text:Observable<String> = Observable<String>.create {
$0.onNext("test")
$0.onNext("test1")
$0.onNext("test2")
return Disposables.create()
}
text.bind(to: observer).disposed(by: disposeBag)
//把文本框當作可監聽對象
let observable = textF.rx.text
observable.subscribe(onNext: {
print($0 as Any)
}).disposed(by: disposeBag)
}
}
複製代碼
另外，框架裏面定義了一些輔助類型，它們既是可監聽序列也是觀察者。若是你能合適的應用這些輔助類型，它們就能夠幫助你更準確的描述事物的特徵：
- AsyncSubject
- PublishSubject
- ReplaySubject
- BehaviorSubject
- ControlProperty」
摘錄來自: RxSwift 中文文檔。
以上幾種輔助類型我將在 RxSwfit 學習筆記（四）中學習探索
相關文章
- 1. Angular2學習筆記——Observable
- 2. Observer Observable
- 3. RxSwfit 學習筆記（五）操做符，合併Observable序列，merge、combineLatest等
- 4. Observer學習筆記
- 5. Angular學習筆記—RxJS與Observable（轉載）
- 6. [譯] 經過構建 Observable 來學習 Observable
- 7. Mobx入門之一：observable & observer
- 8. angular4 http RxJS Observable observer演示
- 9. [RxJS] Subject: an Observable and Observer hybrid
- 10. Rxjava2.0學習筆記（二）
- 更多相關文章...
- • 您已經學習了 XML Schema，下一步學習什麼呢？ - XML Schema 教程
- • 我們已經學習了 SQL，下一步學習什麼呢？ - SQL 教程
- • Tomcat學習筆記（史上最全tomcat學習筆記）
- • Kotlin學習（二）基本類型
相關標籤/搜索
每日一句
-
每一个你不满意的现在，都有一个你没有努力的曾经。
最新文章
- 1. 在windows下的虛擬機中,安裝華爲電腦的deepin操作系統
- 2. 強烈推薦款下載不限速解析神器
- 3. 【區塊鏈技術】孫宇晨：區塊鏈技術帶來金融服務的信任變革
- 4. 搜索引起的鏈接分析-計算網頁的重要性
- 5. TiDB x 微衆銀行 | 耗時降低 58%，分佈式架構助力實現普惠金融
- 6. 《數字孿生體技術白皮書》重磅發佈（附完整版下載）
- 7. 雙十一「避坑」指南：區塊鏈電子合同爲電商交易保駕護航！
- 8. 區塊鏈產業，怎樣「鏈」住未來？
- 9. OpenglRipper使用教程
- 10. springcloud請求一次好用一次不好用zuul Name or service not known
歡迎關注本站公眾號,獲取更多信息
相關文章
- 1. Angular2學習筆記——Observable
- 2. Observer Observable
- 3. RxSwfit 學習筆記（五）操做符，合併Observable序列，merge、combineLatest等
- 4. Observer學習筆記
- 5. Angular學習筆記—RxJS與Observable（轉載）
- 6. [譯] 經過構建 Observable 來學習 Observable
- 7. Mobx入門之一：observable & observer
- 8. angular4 http RxJS Observable observer演示
- 9. [RxJS] Subject: an Observable and Observer hybrid
- 10. Rxjava2.0學習筆記（二）