就問此時(shí)此刻還有誰旨袒？45度仰望天空群扶，該死蜡吧！我這無處安放的魅力休傍！
- RxSwift（1）—— 初探
- RxSwift（2）—— 核心邏輯源碼分析
- RxSwift（3）—— Observable序列的創(chuàng)建方式
- RxSwift（4）—— 高階函數(shù)（上）
- RxSwift（5）—— 高階函數(shù)（下）
- RxSwift（6）—— scheduler源碼解析（上）
- RxSwift（7）—— scheduler源碼解析（下）
- RxSwift（8）—— KVO底層探索（上）
- RxSwift（9）—— KVO底層探索（下）
- RxSwift（10）—— 場(chǎng)景序列總結(jié)
- RxSwift（11）—— 銷毀者-dispose源碼解析
- RxSwift（12）—— Subject即攻也守
- RxSwift（13）—— 爬過的坑
- RxSwift（14）—— MVVM雙向綁定
RxSwift目錄直通車--- 和諧學(xué)習(xí)征绎，不急不躁！
序列在RxSwift的世界里面是非常重要磨取，平時(shí)開發(fā)過程用好序列的創(chuàng)建人柿，能夠給開發(fā)帶來事半功倍的效果！這個(gè)篇章總結(jié)了常用的序列創(chuàng)建方式
1：emty
首先來一個(gè)空的序列 - 本來序列事件是Int類型的,這里調(diào)用emty函數(shù) 沒有序列,只能complete
print("********emty********")
let emtyOb = Observable<Int>.empty()
_ = emtyOb.subscribe(onNext: { (number) in
print("訂閱:",number)
}, onError: { (error) in
print("error:",error)
}, onCompleted: {
print("完成回調(diào)")
}) {
print("釋放回調(diào)")
}
- 這種方式不常用忙厌，但是我們以點(diǎn)及面展開分析
- 通過源碼解析查看
override func subscribe<O: ObserverType>(_ observer: O) -> Disposable where O.E == Element {
observer.on(.completed)
return Disposables.create()
}
- 很明顯在訂閱的時(shí)候凫岖，直接
observer.on(.completed)發(fā)送了完成信號(hào)，非常簡(jiǎn)潔
2： just
- 單個(gè)信號(hào)序列創(chuàng)建
- 該方法通過傳入一個(gè)默認(rèn)值來初始化逢净，構(gòu)建一個(gè)只有一個(gè)元素的
Observable隊(duì)列哥放，訂閱完信息自動(dòng)complete。 - 下面的樣例爹土，我們顯示地標(biāo)注出了
Observable的類型為Observable<[String]>甥雕，即指定了這個(gè)Observable所發(fā)出的事件攜帶的數(shù)據(jù)類型必須是String 類型的
print("********just********")
//MARK: just
// 單個(gè)信號(hào)序列創(chuàng)建
let array = ["LG_Cooci","LG_Kody"]
Observable<[String]>.just(array)
.subscribe { (event) in
print(event)
}.disposed(by: disposeBag)
_ = Observable<[String]>.just(array).subscribe(onNext: { (number) in
print("訂閱:",number)
}, onError: { (error) in
print("error:",error)
}, onCompleted: {
print("完成回調(diào)")
}) {
print("釋放回調(diào)")
}
- 感覺有點(diǎn)數(shù)據(jù)便利的感覺
- 這個(gè)序列在平時(shí)開發(fā)里面還是應(yīng)用挺多的，看看底層源碼
override func subscribe<O: ObserverType>(_ observer: O) -> Disposable where O.E == Element {
observer.on(.next(self._element))
observer.on(.completed)
return Disposables.create()
}
-
observer.on(.next(self._element))常規(guī)訂閱之后就會(huì)發(fā)送.next事件 - 之后就會(huì)自動(dòng)發(fā)送完成事件胀茵，跟我們效果完全吻合
3：of
- 此方法創(chuàng)建一個(gè)新的可觀察實(shí)例社露，該實(shí)例具有可變數(shù)量的元素。
- 該方法可以接受可變數(shù)量的參數(shù)（必需要是同類型的）
print("********of********")
//MARK: of
// 多個(gè)元素 - 針對(duì)序列處理
Observable<String>.of("LG_Cooci","LG_Kody")
.subscribe { (event) in
print(event)
}.disposed(by: disposeBag)
// 字典
Observable<[String: Any]>.of(["name":"LG_Cooci","age":18])
.subscribe { (event) in
print(event)
}.disposed(by: disposeBag)
// 數(shù)組
Observable<[String]>.of(["LG_Cooci","LG_Kody"])
.subscribe { (event) in
print(event)
}.disposed(by: disposeBag)
- 無論
字典,數(shù)組琼娘，多個(gè)元素都是正常使用 - 底層源碼的結(jié)構(gòu)也是中規(guī)中矩
- 初始化保存調(diào)度環(huán)境和傳入的元素
- 訂閱流程也是利用
sink,然后通過mutableIterator迭代器處理發(fā)送
4：from
- 將可選序列轉(zhuǎn)換為可觀察序列峭弟。
- 從集合中獲取序列:數(shù)組,集合,set 獲取序列 - 有可選項(xiàng)處理 - 更安全
print("********from********")
// MARK: from
Observable<[String]>.from(optional: ["LG_Cooci","LG_Kody"])
.subscribe { (event) in
print(event)
}.disposed(by: disposeBag)
-
self._optional = optional底層初始化可選項(xiàng)保存 - 訂閱流程判斷是否匹配我們的可選項(xiàng)
- 發(fā)送
observer.on(.next(element))序列 - 隨即自動(dòng)
observer.on(.completed)完成序列發(fā)送
5：deferred
- 返回一個(gè)可觀察序列，該序列在新觀察者訂閱時(shí)調(diào)用指定的工廠函數(shù)脱拼。
- 這里有一個(gè)需求:動(dòng)態(tài)序列 - 根據(jù)外界的標(biāo)識(shí) - 動(dòng)態(tài)輸出
- 使用
deferred()方法延遲Observable序列的初始化瞒瘸，通過傳入的block來實(shí)現(xiàn)Observable序列的初始化并且返回。
print("********defer********")
//MARK: defer
var isOdd = true
_ = Observable<Int>.deferred { () -> Observable<Int> in
// 這里設(shè)計(jì)我們的序列
isOdd = !isOdd
if isOdd {
return Observable.of(1,3,5,7,9)
}
return Observable.of(0,2,4,6,8)
}
.subscribe { (event) in
print(event)
}
-
self._observableFactory = observableFactory初始化保存了這段工廠閉包
func run() -> Disposable {
do {
let result = try self._observableFactory()
return result.subscribe(self)
}
catch let e {
self.forwardOn(.error(e))
self.dispose()
return Disposables.create()
}
}
- 在訂閱流程到
sink的時(shí)候熄浓，把這段工廠閉包執(zhí)行 - 有種中間層被包裝的感覺
6：rang
- 使用指定的調(diào)度程序生成并發(fā)送觀察者消息情臭，生成指定范圍內(nèi)的可觀察整數(shù)序列。
print("********rang********")
//MARK: rang
Observable.range(start: 2, count: 5)
.subscribe { (event) in
print(event)
}.disposed(by: disposeBag)
// 底層源碼
init(start: E, count: E, scheduler: ImmediateSchedulerType) {
self._start = start
self._count = count
self._scheduler = scheduler
}
override func run<O : ObserverType>(_ observer: O, cancel: Cancelable) -> (sink: Disposable, subscription: Disposable) where O.E == E {
let sink = RangeSink(parent: self, observer: observer, cancel: cancel)
let subscription = sink.run()
return (sink: sink, subscription: subscription)
}
- 保存序列中第一個(gè)整數(shù)的值赌蔑。
- 保存要生成的順序整數(shù)的數(shù)目谎柄。
- 保存調(diào)度環(huán)境
if i < self._parent._count {
self.forwardOn(.next(self._parent._start + i))
recurse(i + 1)
}
else {
self.forwardOn(.completed)
self.dispose()
}
- 根據(jù)之前保存的信息，數(shù)據(jù)的狀態(tài)也不斷攀升惯雳，然后遞歸到規(guī)定的要求
7：generate
- 通過運(yùn)行產(chǎn)生序列元素的狀態(tài)驅(qū)動(dòng)循環(huán)朝巫，使用指定的調(diào)度程序運(yùn)行循環(huán)，發(fā)送觀察者消息石景，從而生成一個(gè)可觀察序列劈猿。
- 該方法創(chuàng)建一個(gè)只有當(dāng)提供的所有的判斷條件都為
true的時(shí)候拙吉，才會(huì)給出動(dòng)作的Observable序列。 - 初始值給定 然后
判斷條件1再判斷條件2會(huì)一直遞歸下去,直到條件1或者條件2不滿足 - 類似 數(shù)組遍歷循環(huán)
- -參數(shù)一
initialState: 初始狀態(tài)揪荣。 - -參數(shù)二
condition：終止生成的條件(返回“false”時(shí))筷黔。 - -參數(shù)三
iterate：迭代步驟函數(shù)。 - -參數(shù)四 調(diào)度器：用來運(yùn)行生成器循環(huán)的調(diào)度器仗颈，默認(rèn)：
CurrentThreadScheduler.instance佛舱。 - -返回：生成的序列。
print("********generate********")
//MARK: generate
Observable.generate(initialState: 0,// 初始值
condition: { $0 < 10}, // 條件1
iterate: { $0 + 2 }) // 條件2 +2
.subscribe { (event) in
print(event)
}.disposed(by: disposeBag)
// 數(shù)組遍歷
let arr = ["LG_Cooci_1","LG_Cooci_2","LG_Cooci_3","LG_Cooci_4","LG_Cooci_5","LG_Cooci_6","LG_Cooci_7","LG_Cooci_8","LG_Cooci_9","LG_Cooci_10"]
Observable.generate(initialState: 0,// 初始值
condition: { $0 < arr.count}, // 條件1
iterate: { $0 + 1 }) // 條件2 +2
.subscribe(onNext: {
print("遍歷arr:",arr[$0])
})
.disposed(by: disposeBag)
8：timer
- 返回一個(gè)可觀察序列挨决，該序列使用指定的調(diào)度程序運(yùn)行計(jì)時(shí)器请祖，在指定的初始相對(duì)到期時(shí)間過后定期生成一個(gè)值。
- 第一次參數(shù):第一次響應(yīng)距離現(xiàn)在的時(shí)間
- 第二個(gè)參數(shù):時(shí)間間隔
- 第三個(gè)參數(shù):線程
print("********timer********")
//MARK: timer
Observable<Int>.timer(5, period: 2, scheduler: MainScheduler.instance)
.subscribe { (event) in
print(event)
}
.disposed(by: disposeBag)
// 因?yàn)闆]有指定期限period,故認(rèn)定為一次性
Observable<Int>.timer(1, scheduler: MainScheduler.instance)
.subscribe { (event) in
print("111111111 \(event)")
}
//.disposed(by: disposeBag)
- 狀態(tài)碼的不斷攀升脖祈，間隔時(shí)間不斷發(fā)送響應(yīng)
9：interval
- 返回一個(gè)可觀察序列肆捕，該序列在每個(gè)周期之后生成一個(gè)值，使用指定的調(diào)度程序運(yùn)行計(jì)時(shí)器并發(fā)送觀察者消息盖高。
print("********interval********")
//MARK: interval
// 定時(shí)器
Observable<Int>.interval(1, scheduler: MainScheduler.instance)
.subscribe { (event) in
print(event)
}
//.disposed(by: disposeBag)
9：repeatElement
- 使用指定的調(diào)度程序發(fā)送觀察者消息慎陵，生成無限重復(fù)給定元素的可觀察序列。
print("********repeatElement********")
//MARK: repeatElement
Observable<Int>.repeatElement(5)
.subscribe { (event) in
// print("訂閱:",event)
}
.disposed(by: disposeBag)
10：error
- 返回一個(gè)以“error”結(jié)束的可觀察序列喻奥。
- 這個(gè)序列平時(shí)在開發(fā)也比較常見席纽，請(qǐng)求網(wǎng)絡(luò)失敗也會(huì)發(fā)送失敗信號(hào)！
print("********error********")
//MARK: error
// 對(duì)消費(fèi)者發(fā)出一個(gè)錯(cuò)誤信號(hào)
Observable<String>.error(NSError.init(domain: "lgerror", code: 10086, userInfo: ["reason":"unknow"]))
.subscribe { (event) in
print("訂閱:",event)
}
.disposed(by: disposeBag)
11：never
- 該方法創(chuàng)建一個(gè)永遠(yuǎn)不會(huì)發(fā)出
Event（也不會(huì)終止）的Observable序列撞蚕。 - 這種類型的響應(yīng)源 在測(cè)試或者在組合操作符中禁用確切的源非常有用
print("********never********")
//MARK: never
Observable<String>.never()
.subscribe { (event) in
print("走你",event)
}
.disposed(by: disposeBag)
print("********never********")
12：create()
- 該方法接受一個(gè) 閉包形式的參數(shù)胆筒，任務(wù)是對(duì)每一個(gè)過來的訂閱進(jìn)行處理。
- 下面是一個(gè)簡(jiǎn)單的樣例诈豌。為方便演示，這里增加了訂閱相關(guān)代碼
- 這也是序列創(chuàng)建的一般方式抒和，應(yīng)用非常之多
let observable = Observable<String>.create{observer in
//對(duì)訂閱者發(fā)出了.next事件矫渔，且攜帶了一個(gè)數(shù)據(jù)"hangge.com"
observer.onNext("hangge.com")
//對(duì)訂閱者發(fā)出了.completed事件
observer.onCompleted()
//因?yàn)橐粋€(gè)訂閱行為會(huì)有一個(gè)Disposable類型的返回值，所以在結(jié)尾一定要returen一個(gè)Disposable
return Disposables.create()
}
//訂閱測(cè)試
observable.subscribe {
print($0)
}
序列的創(chuàng)建也是學(xué)習(xí)
RxSwift的根基摧莽，有很多時(shí)候我遇到很多的BUG,說白了就是根基沒有掌握好庙洼！現(xiàn)在我們的已經(jīng)RxSwift第十節(jié)課上完了,很多同學(xué)對(duì)RxSwift有了一個(gè)比較深入的了解，當(dāng)然這里我還是以博客的形式寫出來镊辕，就是希望大家能夠及時(shí)回來看看油够，我知道，肯定會(huì)有很多同學(xué)回來繼續(xù)加深基礎(chǔ)的征懈！就問此時(shí)此刻還有誰石咬？45度仰望天空，該死卖哎！我這無處安放的魅力鬼悠！
