RxSwift实战-基于MVVM

基于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，就是加入都一个地方，然后方便释放资源。
  所以当我点击按钮，生产线启动，一步步进行直到有问题结束或者完成结束。