ReactiveCocoa - Swift 解读系列二：Oberser如何停止对一个Signal的观察

在上一篇文章中，讲到了RAS中Signal的创建和使用，展示了从Signal创建到绑定观察者以及发送的过程。本文将介绍关于Signal 与Oberser之间的解绑关系。

上篇文章开始的示意图中，我们知道，除了本身的发送器，所有的观察者Oberser对象存在Signal的Bag（之前已经讲过，这是一个集合结构体，我们将它看作一个数组类似的东西即可，它被当成Signal状态的一个关联之放在Signal中）中了。如果我们要将一个观察者加入到Signal，可以使用Signal的绑定函数：

    public func observe(_ observer: Observer) -> Disposable? {
        return core.observe(observer)
    }

这个函数调用Signal中Core类的func observe(oberser)函数，具体的实现看下图：

Core 中绑定观察者

函数中，首先会判断Signal本身的状态State（这是一个枚举，包括aLive和terminating以及terminated三种状态)，如果处于aLive（活跃）状态的时候，则会将观察者加入到Signal的bag中，完成绑定。否则，观察者observer将发送一个中断事件。

注意观察者observer在加入到bag之后，Bag 的token会发生相应的变化，这个token中包含的就是observer在Bag中的类似索引机制，Bag通过操作token来控制内部的observer。如果变化后的token是有效的，那么将会创建observer对应的Disposable。并实现Disposable的一个回调函数action： ()->(Void).其内容正如我们看到的，在bag内部将observer删除，这样就是消除了observer对Signal信号消息的观察。最后整个函数将这个Disposable返回。

也就是说Disposable有一套内部的逻辑，在合适的时候，调用其action函数，从而将observer解除。我们再看看Disposable到底是什么鬼。

在Disposable源码中：

Disposable

包含一个Bool变量 var isDisposed: Bool { get }和一个清理函数 func dispose()。可以说很简单，我们基本上可以猜测到，isDisposed存储的是Disposable本身是否被（在Oberser 被清理出Bag后这个状态将会为true）；而dispose()就是将Oberser的绑定解除的函数。

Signal并没有直接遵循这个协议，而是会使用遵循了下面这个协议的几个类：

_SimpleDisposable

这个类是Disposable类族中的一个基本类，也是一个internal类，使用者不会直接使用到它。它只负责创建一个Disposable的空类，也即是没有消费过的Disposable。

NopDisposable

创建一个已经被消费的Disposable。它除了能知道一个Disposable的状态之外没有其他作用。

AnyDisposable

AnyDisposable是创建一个有效的Disposable最主要的方式。我们在建立一个Signal和Oberser绑定的时候，其中返回的Disposable就是一个AnyDisposable对象。

CompositeDisposable

综合类型Disposable，它的内部又一个包含AnyDisposable的bag。并重载了+= 运算符。使用它可以持续的添加其他的AnyDisposable加入到bag中。

ScopedDisposable

Disposable的封包。支持对AnyDisposable和CompositeDisposable的封装。

SerialDisposable

一系列的Disposable。

这篇文章主要讲解`Oberser`如何退出观察的，也即是重点讲解下`AnyDisposable`。以下是`AnyDisposable`的源码：

`AnyDisposable`

AnyDisposable继承自Disposable。内包含一个ActionDisposable,这个类类似于Signal的Core.RAS大量的采用了内嵌类的设计模式。

除了ActionDisposable之外，AnyDisposable含有三个初始化函数。我们主要讲下 public init(_ action: @escaping () -> Void){}.因为在 Oberser和Signal绑定的时候，就是使用了这个函数。

action参数是一个无参函数，它是一个尾随闭包。最终我们看到通过ActionDisposable将这个闭包给了ActionDisposable的action。而在func dispose()的执行中，调用了这个闭包。也即是我们在使用AnyDisposable进行解绑的时候，实际调用了我们在绑定时候传入的一个闭包：