最近在重写的项目中使用了RXSwift,下面使用一个登陆的界面来说明一下RXSwift的使用过程
init(phoneNum: Observable<String>,
pwdNum: Observable<String>,
loginTap: Observable<Void>) {
//判断手机号码框输入是否正确
phoneEnable = phoneNum.map({ (phone) in
return phone.length == 11
}).shareReplay(1)
//判断 密码框输入是否合法
pwdEnable = pwdNum.map({ (pwd) in
return pwd.length >= 6
}).shareReplay(1)
//登陆按钮是否可以点击
loginEnable = Observable.combineLatest(phoneEnable, pwdEnable) {($0,$1)}.map({ (x,y) in
return x && y
}).shareReplay(1)
let phoneAndPwd = Observable.combineLatest(phoneNum, pwdNum) {($0,$1)}.shareReplay(1)
//登陆的结果
loginResult = loginTap.withLatestFrom(phoneAndPwd).flatMap({ (phone, pwd) in
//ALTools自己封装的一个Alamofire支持rx的方法
return ALTools().rx_RequestXML(loginApi.login(phone: phone, pwd: pwd)).map({ (data) in
let json = JSON(data: data)
.......
//正确解析后
return true
}).catchErrorJustReturn(false)
})
}
let viewModel = LoginViewModel(phoneNum: self.phoneField.rx.text.orEmpty.asObservable(), pwdNum: self.pwdField.rx.text.orEmpty.asObservable(), loginTap: self.loginBT.rx.tap.asObservable())
viewModel. phoneEnable.subscrib(onNext: { (result) in
//手机号码是否合法的一些操作
...
}).addDisposableTo(disposeBag)
viewModel. pwdEnable(onNext: { (result) in
//密码是否合法的一些操作
...
}).addDisposableTo(disposeBag)
viewModel.loginEnable.subscribe(onNext: { (result) in
//登陆按钮是否可以点击的一些操作
loginBT.backgroundColor = result ? NavbarColor:UIColor.lightGray
self.loginBT.isEnabled = result
}).addDisposableTo(disposeBag)
viewModel.loginResult.subscribe(onNext: { (result) in
//登陆是否成功
if result {
let user: User! = User.info
SLLog(message: "学校:\(user.schID!),用户:\(user.userName!)")
let controller = HomeViewController()
self.navigationController?.pushViewController(controller, animated: true)
}
}).addDisposableTo(disposeBag)
下一节:RxSwift+MJRefresh+Realm实现tableView的刷新(分页)