RxSwift-RxExample 学习系列（一）

最近Rx项目写的头昏脑胀，刷一遍官方demo清醒一下。

1.add numbers

demo1.png

第一个demo 其实就是3个label 加法运算得出结果。

Observable.combineLatest(number1.rx.text.orEmpty, number2.rx.text.orEmpty, number3.rx.text.orEmpty) { textValue1, textValue2, textValue3 -> Int in
                return (Int(textValue1) ?? 0) + (Int(textValue2) ?? 0) + (Int(textValue3) ?? 0) //合并最近信号 返回最新结果
            }
            .map { $0.description } //int -> String
            .bind(to: result.rx.text) // 结果绑定到结果label上
            .disposed(by: disposeBag) 

这里要combinLatest组合运算符

image.png
是帮每个Observable 发出的最新的消息组合到一起成为一个新的值。
============这里区分merge 合并
image.png
merge只是将每个Observable发的值 组成一个新的消息序列

2simple validation

image.png

这个例子 真的是给国内博客抄烂了0.0
-username_textfiled的信号控制着password_textfiled的 可写 和 username的提示

let usernameValid = usernameOutlet.rx.text.orEmpty
            .map { $0.count >= minimalUsernameLength }
            .share(replay: 1) // without this map would be executed once for each binding, rx is stateless by default

这里要注意的是share rx是无状态的 每次被订阅都会重复执行操作.加上share 无论多少次订阅都会执行一次处理操作。

这也是 Observable和Driver的区别之一
订阅

usernameValid
            .bind(to: passwordOutlet.rx.isEnabled)
            .disposed(by: disposeBag)
 usernameValid
            .bind(to: usernameValidOutlet.rx.isHidden)
            .disposed(by: disposeBag)

这里确认按钮处理也和上面第一例子一样 当username 和 password 同时满足条件才触发确认按钮的状态

let everythingValid = Observable.combineLatest(usernameValid, passwordValid) { $0 && $1 }
            .share(replay: 1)
everythingValid
            .bind(to: doSomethingOutlet.rx.isEnabled)
            .disposed(by: disposeBag)

3 Geolocation Subscription

image.png

这个例子主要就是
获取定位权限 -> 定位刷新 -> 显示定位坐标
-> 定位失败 -> 显示定位失败占位图

主要代码就是封装定位处理。让定位授权 和 实时坐标 成为Obserable
1 授权

authorized = Observable.deferred { [weak locationManager] in
                let status = CLLocationManager.authorizationStatus()
                guard let locationManager = locationManager else {
                    return Observable.just(status)
                }
                return locationManager
                    .rx.didChangeAuthorizationStatus
                    .startWith(status)
            }
            .asDriver(onErrorJustReturn: CLAuthorizationStatus.notDetermined)
            .map{
                switch $0 {
                case .authorizedAlways:
                    return true
                default:
                    return false
                }
            }

这里第一要看的就是defer 订阅延迟创建信号序列。一开始我对defer 和 create 区别不是很懂。最后发现create 也是订阅时候创建。那意思就是2者没啥区别咯。

然后这里的 return locationManager .rx.didChangeAuthorizationStatus .startWith(status) 我真的觉得可以直接just(status)
然后map 转换为bool 类型

绑定 占位图 是否隐藏

geolocationService.authorized
            .drive(noGeolocationView.rx.isHidden)
            .disposed(by: disposeBag)

定位 封装

location = locationManager.rx.didUpdateLocations
            .asDriver(onErrorJustReturn: [])
            .flatMap {
                return $0.last.map(Driver.just) ?? Driver.empty()
            }
            .map { $0.coordinate }

这个没啥好说的直接转化 coordinate 然后绑定显示