基于rxswift实现响应式编程，使一个复杂的逻辑能在一个地方完成，这样的代码更加地方便阅读更加一目了然。当然它的作用并不仅限于此，还可以更方便地实现基于MVVM模式的项目。
以登录为例，我的登录流程是这样的：
1.检查账号，密码输入的有效性，如果无效，弹出菊花提示；如果有效，下一步。
2.登录请求前一系列的处理，例如注销键盘第一响应者，弹出等待菊花.......
3.服务器请求
4.处理返回结果
// 首先我会在viewModel中初始化一个LoginInputStatus枚举类型的属性，用于提示账号和密码的有效性的状态，
// 例如一下
// viewModel里面的属性，初始化
lazy validMessage: LoginInputStatus = LoginInputStatus.CanLogin
// 枚举
enum LoginInputStatus: String {
case CanLogin = ""
case WrongPhone = "手机号码不正确"
case NilPhoneOrPwd = "手机号或密码不能为空"
.......
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
}
}
}
// 组合两个信号,并订阅该组合信号
_ = 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)
然后是封装我们的网络请求，代码类似于：
func getLogin() -> Observable<NetWorkResult<返回数据模型类型>> {
return Observable.create { [weak self] observer -> Disposable in
let request = HLNetwork.shareNetwork().sendRequest(API, parameter: 请求参数, success: { [weak self](objc) in
observer.onNext(NetWorkResult.value(数据))
}) { (objc) in
observer.onNext(NetWorkResult.error(objc))
}
return AnonymousDisposable {
request.cancel()
}
}
}```
接下来就是一整个流程了
_ = 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秒内值发生多次变化取最后一次变化的值，其实这里好奇怪，因为需要这样，菊花提示才会正常弹出，当初考虑过会不会是在非主线程操作的原因，用到observeOn，但是问题依然存在。而且这个问题在其他的类似请求中并不会出现，所以可以根据实际情况来判断是否需要加上去。
filter过滤操作，我需要在请求前过滤掉无效的请求参数。参数符合要求，则继续；不符合弹出菊花提示并终止这一次的点击。
doOn就是请求前的一系列的准备了，正如我上面所说，这里我注销了键盘的第一响应者并弹出等待菊花。
flatMap在这里的作用是请求服务器和信号的转换。将点击信号转换成getLogin返回的信号，该返回信号包含了我们想要的数据。
subscribeNext就是订阅事件了，如果不加上点击事件就不会触发。
addDisposableTo原理像以前的autoreleasepool，就是加入都一个地方，然后方便释放资源。
所以当我点击按钮，生产线启动，一步步进行直到有问题结束或者完成结束。