基于rxswift實(shí)現(xiàn)響應(yīng)式編程，使一個(gè)復(fù)雜的邏輯能在一個(gè)地方完成，這樣的代碼更加地方便閱讀更加一目了然能真。當(dāng)然它的作用并不僅限于此旅急，還可以更方便地實(shí)現(xiàn)基于MVVM模式的項(xiàng)目逢勾。
以登錄為例，我的登錄流程是這樣的：
??1.檢查賬號(hào)藐吮，密碼輸入的有效性溺拱，如果無效，彈出菊花提示谣辞；如果有效迫摔，下一步。
??2.登錄請(qǐng)求前一系列的處理泥从，例如注銷鍵盤第一響應(yīng)者句占，彈出等待菊花.......
??3.服務(wù)器請(qǐng)求
??4.處理返回結(jié)果
// 首先我會(huì)在viewModel中初始化一個(gè)LoginInputStatus枚舉類型的屬性，用于提示賬號(hào)和密碼的有效性的狀態(tài)躯嫉，
// 例如一下
// viewModel里面的屬性纱烘，初始化
lazy validMessage: LoginInputStatus = LoginInputStatus.CanLogin
// 枚舉
enum LoginInputStatus: String {
case CanLogin = ""
case WrongPhone = "手機(jī)號(hào)碼不正確"
case NilPhoneOrPwd = "手機(jī)號(hào)或密碼不能為空"
.......
static func getMessage(user: String, pwd: String) -> LoginInputStatus {
if user.characters.count != 11 {
return LoginStatus.WrongPhone
}
else if user.characters.count == 0 || pwd.characters.count == 0 {
return LoginStatus.NilPhoneOrPwd
}
......
else {
return LoginStatus.CanLogin
}
}
}
// 組合兩個(gè)信號(hào),并訂閱該組合信號(hào)
_ = Observable.combineLatest(self.vc.text_name.rx_text, self.vc.text_password.rx_text) { value1, value2 -> (String, String) in
return (value1, value2)
}
.subscribeNext { (res: (String, String)) in
self.validMessage = LoginStatus.getMessage(res.0, pwd: res.1)
}.addDisposableTo(disposBag)
然后是封裝我們的網(wǎng)絡(luò)請(qǐng)求，代碼類似于：
func getLogin() -> Observable<NetWorkResult<返回?cái)?shù)據(jù)模型類型>> {
return Observable.create { [weak self] observer -> Disposable in
let request = HLNetwork.shareNetwork().sendRequest(API, parameter: 請(qǐng)求參數(shù), success: { [weak self](objc) in
observer.onNext(NetWorkResult.value(數(shù)據(jù)))
}) { (objc) in
observer.onNext(NetWorkResult.error(objc))
}
return AnonymousDisposable {
request.cancel()
}
}
}```
接下來就是一整個(gè)流程了
_ = self.loginBtn.rx_tap
.throttle(0.1, scheduler: MainScheduler.instance)
.filter({ [weak self](_) -> Bool in
if self!.vm.validMessage == LoginStatus.CanLogin {
return true
}
else {
MBProgressHUD.showError(self!.vm.validMessage.rawValue)
return false
}
})
.doOn({ (ee) in
self.text_name.resignFirstResponder()
self.text_password.resignFirstResponder()
MBProgressHUD.showMessage("登錄中")
})
.flatMap{ self.vm.getLogin() }
.subscribeNext({ [weak self](result) in
MBProgressHUD.hideHUD()
switch result {
case .value(let value):
MBProgressHUD.showSuccess(value.Mess as String)
break
case .error(let error):
MBProgressHUD.showError(error)
break
}
})
.addDisposableTo(self.vm.disposBag)
throttle意思是主線程操作下面的代碼祈餐，0.1秒內(nèi)值發(fā)生多次變化取最后一次變化的值擂啥，其實(shí)這里好奇怪，因?yàn)樾枰@樣帆阳，菊花提示才會(huì)正常彈出哺壶，當(dāng)初考慮過會(huì)不會(huì)是在非主線程操作的原因，用到observeOn，但是問題依然存在山宾。而且這個(gè)問題在其他的類似請(qǐng)求中并不會(huì)出現(xiàn)至扰，所以可以根據(jù)實(shí)際情況來判斷是否需要加上去。
??filter過濾操作塌碌，我需要在請(qǐng)求前過濾掉無效的請(qǐng)求參數(shù)渊胸。參數(shù)符合要求，則繼續(xù)台妆；不符合彈出菊花提示并終止這一次的點(diǎn)擊翎猛。
??doOn就是請(qǐng)求前的一系列的準(zhǔn)備了，正如我上面所說接剩，這里我注銷了鍵盤的第一響應(yīng)者并彈出等待菊花切厘。
??flatMap在這里的作用是請(qǐng)求服務(wù)器和信號(hào)的轉(zhuǎn)換。將點(diǎn)擊信號(hào)轉(zhuǎn)換成getLogin返回的信號(hào)懊缺，該返回信號(hào)包含了我們想要的數(shù)據(jù)疫稿。
??subscribeNext就是訂閱事件了，如果不加上點(diǎn)擊事件就不會(huì)觸發(fā)鹃两。
??addDisposableTo原理像以前的autoreleasepool遗座，就是加入都一個(gè)地方，然后方便釋放資源俊扳。
??所以當(dāng)我點(diǎn)擊按鈕途蒋，生產(chǎn)線啟動(dòng)，一步步進(jìn)行直到有問題結(jié)束或者完成結(jié)束馋记。