RxSwift初窥
前言
很久一段时间没写博客了，一方面是自己各种事情折腾，二是新项目开始用Swift了，边学边做忙死了，现在终于快忙完了。由于接下来项目要使用RxSwift，所以研究一下RxSwift。
RxSwift概要
RxSwift是Swift函数响应式编程的一个开源库，由Github的ReactiveX组织开发，维护。目前在GitHub上有10000+star。
RxSwift的目的是让让数据/事件流和异步任务能够更方便的序列化处理，能够使用Swift进行响应式编程。
RxSwift中的基本概念
Observable
在ReactiveX中一个观察者(Observer)订阅一个被观察的对象。这个观察者对Observable发出的无论是单个对象或者是一串对象作出反馈。这种模式有利于并发操作因为它不需要阻塞线程，当等待一个Observable发送对象的过程中，它建立一种像哨兵一样的机制，我们称之为观察者，他会一直关注那个Observable然后做出适当的反应。在ReactiveX对Observable的说明中，有这么一张图：
legend.png
在最上面的一排，就是一个Observable。从左到右，表示时间由远到进的流动过程。上面的每一个形状，就表示在某个时间点发生的事件，而最右边的竖线则表示事件成功结束。
Operators
在RxSwift中，操作符operator也是一个很重要的概念，关于它的详细介绍在ReactiveX官网可以看到。常用操作符分为两大类，一类用于创建Observable；这些不同的方法可以针对不同的事件流生成Observable。另一类是接受Observable作为参数，并返回意义新的Observable。
创建一个事件队列
创建一个简单的事件队列很简单,代码如下：
_ = Observable.of(1,2,3,4,5,6,7,8,9)
_ = Observable.from([1,2,3,4,5,6,7,8,9])
上面这里我们就用了两个operator来创建Observable：
-
of: 用固定数量的元素生成一个Observable； -
from: 用一个Sequence类型的对象创建一个Observable；
这两个operator返回的结果是一样的，都是一个包含1-9的Observable。
处理事件序列
在开发中，我们有时候因为各种需求需要对事件序列进行处理加工。例如我要把上面的事件序列变成一个字符串序列，用map操作符就可以做到。
_ = Observable.of(1,2,3,4,5,6,7,8,9).map({String($0)})
map是一个可以对Observable中的元素变形的operator，它返回一个新的Observable对象。
我们还可以筛选出符合条件的事件序列
_ = Observable.of(1,2,3,4,5,6,7,8,9).filter({$0 % 2 == 0})
上面filter筛选出一个只含有偶数的时间序列
看到filter和map感觉和集合中的filter和map方法非常类似，但它们执行的逻辑却截然不同。调用集合类型中的filter和map方法，表达的是同步执行的概念，在调用方法的同事，结合就被立即加工处理了。但是我们创建的bservable，表达的是异步操作。Observable中的每一个元素，都可以理解为一个异步发生的时间。因此，当我们队Observable调用filter和map方法时，只表示我们要对事件序列中的元素进行处理的逻辑，并不会立即对Observable中的元素进行处理。下面这个例子可以验证：
_ = Observable.of(1,2,3,4,5,6,7,8,9)
.filter({
if $0 % 2 == 0 {
print($0)
return true
}
return false
})
执行这段代码，在控制台上并没有打印任何消息。也就是说，我们没有实际执行任何的筛选逻辑。
订阅事件
上面的刷选什么时候会被执行呢？那就是有人订阅这个事件的时候。
let numberObservable = Observable.of(1,2,3,4,5,6,7,8,9)
.filter({
if $0 % 2 == 0 {
print($0)
return true
}
return false
})
numberObservable.subscribe { (event) in
print("event: \(event)")
}
上面这段代码的执行结果如下：
2
event: next(2)
4
event: next(4)
6
event: next(6)
8
event: next(8)
event: completed
这说明当我们订阅了这个事件序列，我们就能够关注到筛选的过程和结果了。
subscribe也是一个operator
在上面的例子中，我们可以看到最后有一个event: completed，这就表示Observable事件流成功结束了。
实际上，subscribe也是一个operator，用于把事件的订阅者(Observer)和事件的产生者(Observable)关联起来。而Observable和Observer之间，有着以下的约定：
- 当Observable正常发送事件时，会调用Observer提供的onNext方法，这个过程给你习惯上叫做emissions;
- 当Observable成功结束时，回到用Observer提供的onCompleted方法；因此，在最后一次调用onNext之后，就会调用onCompleted；
- 当Observable发生错误时，就会调用Observer提供的onError方法，并且，一旦发生错误，就不会再继续发送其他时间了。对于调用onComplete和onNext的过程，习惯上叫做notifications;
在RxSwift里，还有一个约定，叫做onDisposed，指的是Observable使用的资源被回收的时候，会调用Observer提供的onDisposed方法。
Observable dispose
一般情况下，Observable分为两种：
- 在有限的时间内会自动结束(Completed/Error),比如一个网络请求当做一个序列，当网络请求完成的时候，Observable自动结束，资源会被释放
- 信号不会自己结束，最简单的就是一个Timer，每隔一段时间就会发送一个新的信号过来，这时候就需要手动监听来释放相应的资源。
手动监听释放也分为两种方法，分别是显式释放以及隐式释放：
- 显式释放 直接调用释放方法进行资源的释放，如下面的实例
public func delay(_ delay: Double,
closure: @escaping (Void) -> Void) {
DispatchQueue.main.asyncAfter(
deadline: .now() + delay) {
closure()
}
}
let disposable =
Observable<Int>.interval(1, scheduler: MainScheduler.instance)
.subscribe(
onNext: { print("Subscribed: \($0)") },
onDisposed: { print("The queue was disposed.") })
delay(3) {
disposable.dispose()
}
执行效果如下：
Subscribed: 0
Subscribed: 1
Subscribed: 2
The queue was disposed.
上面代码创建一个辅助函数delay()，然后在delay()之后直接调用dispose()方法，这是显式释放
- 隐式释放 通过DisposeBag来进行，它类似于Objective-C中ARC的自动释放池机制，当我们创建了某个实例后，会被添加到所在线程的自动释放池中，而自动释放池会在一个RunLoop周期后进行池子的释放与重建；DisposeBag对于Rxswift就像自动释放池一样，我们把资源天机到DisposeBag中，让资源随着DIsposeBag一起释放。如下实例：
var bag = DisposeBag()
Observable<Int>.interval(1, scheduler: MainScheduler.instance)
.subscribe(
onNext: { print("Subscribed: \($0)") },
onDisposed: { print("The queue was disposed.") })
.disposed(by: bag)
delay(3) {
bag = DisposeBag()
}
这个执行效果和上面的是一样的，这就是隐式释放。
小结
RxSwift之路还很长，需要不断学习，不断积累。
