本文主要认识RxSwift的原理，以及简单使用，实现监听响应操作
主要内容：
- 响应式编程的认识
- RxSwift的原理认识
- RxSwift的简单使用
1、 响应式编程
响应式编程（Reactive Programming ，简称RP），也是一种编程范式，于1997年提出，可以简化异步编程，提供更优雅的数据绑定。
一般与函数式融合在一起，所以也会叫做：函数响应式编程（ Functional Reactive Programming ，简称FRP）
框架介绍
比较成熟的、著名的响应式框架有两种：
- ReactiveCocoa，简称RAC，只有OC和Swift版本
- ReactiveX，简称Rx，有多种编程语言版本，没有OC的，有RxSwift（RxSwift（ReactiveX for Swift）， ReactiveX的Swift版本）
2、 RxSwift的原理
两个核心角色：
- Observable：负责发送事件（Event）
- Observer：负责订阅Observable ，监听Observable发送的事件（ Event）
订阅和监听过程：
说明：
- Observer先订阅Observable。也就是绑定到Observable监听对象
- Observable发送事件序列
- 事件触发后会推送到Observer进行监听
事件：
public enum Event<Element> {
/// Next element is produced.
case next(Element)
/// Sequence terminated with an error.
case error(Swift.Error)
/// Sequence completed successfully.
case completed
}
说明：
- 事件有三种，通过枚举来存储
- next：
- 发送的信息会携带具体数据
- 是一个关联值，发送的值是定义事件时传入的
- error：
- 携带错误信息
- 终止Observable，不会再发出事件
- completed：
- 表明Observable终止，不会再发出事件
3、 基本实现
3.1 事件监听
3.1.1 触发事件
//1. 触发事件
var observable = Observable<Int>.create { observer in
observer.onNext(1)
observer.onCompleted()
return Disposables.create()
}
// 等价于
observable = Observable.just(1)
observable = Observable.of(1)
observable = Observable.from([1])
var observable = Observable<Int>.create { observer in
observer.onNext(1)
observer.onNext(2)
observer.onNext(3)
observer.onCompleted()
return Disposables.create()
}
// 等价于
observable = Observable.of(1, 2, 3)
observable = Observable.from([1, 2, 3])
说明：
- 在创建Observable的时候就可以通过闭包表达式来发送消息
- 这里的onNext就是发送一次消息
- onCompleted()就是停止发送
- just()/of()/from()也是发送一次消息，参数就是发送的信息
- 但是他们发送后就会停止发送
- 因此他们就等价于上面的onNext()+onCompleted()
- of和from可以一次性发送多个消息，而just只能发送一次消息
3.1.2、订阅接收事件
//2. 订阅接收事件
observable.subscribe { event in
print(event)
}.dispose()
observable.subscribe(onNext: {
print("next", $0)
}, onError: {
print("error", $0)
}, onCompleted: {
print("completed")
}, onDisposed: {
print("dispose")
}).dispose()
说明：
- 此处进行监听事件
- 通过订阅后才能监听到事件
3.1.3 取消订阅
disposed：
observable.subscribe { event in
print(event)
}.dispose()
- 这里是一次性订阅，当发送消息后就会取消订阅
takeUtil：
observable
.takeUtil(self.rx.deallocted)
.map { "数值是：\($0)" }
.bind(to: label.rx.text)
- 此处表示当self生命周期结束后，订阅取消
- 所有的NSObject都会有rx
3.3 监听者
observer代码：
let observer = AnyObserver<Int>.init { event in
switch event {
case .next(let data):
print(data)
case .completed:
print("completed")
case .error(let error):
print("error", error)
}
}
Observable.just(1).describe(observer).dispose()
说明：
- observer都通过AnyObserver实现，初始化时直接创建event的响应操作
- 总共有三种监听样式
binder：
Observable.just(1).describe(observer).dispose()
let binder = Binder<String>(label) {label, value in
label.text = value
}
observerable.just(1).map{ "数值是\($0)" }.subscribe(binder).dispose()
observerable.just(1).map{ "数值是\($0)" }.bind(to: binder).dispose()
说明：
- binder也可以作为监听者，监听数据的改变。
- 同时需要注意这里监听方式有两种，他们的效果是完全一样的，是等价的
- 传入的label就是需要绑定的对象
- 传入的value就是绑定的数据
3.3 时间监听
//时间监听
let observable = Observable<Int>.timer(.seconds(3),
period: .seconds(1),
scheduler: MainScheduler.instance)
observable.map { "数值是\($0)" }
.bind(to: label.rx.text)
.disposed(by: bag)
说明：
- 第一个参数是枚举值很好用，最后的一个参数是设置线程的
- Observable通过.bind绑定label的rx的text
- 可以通过map来修改值
- label.rx.text就是Observer
- disposed就表示不再接收订阅，当bag销毁的时候就可以取消订阅
