ReactiveCocoa - Swift 解读系列三:Sign
SignalProducer是RAS对Signal的封装。之前我们使用Signal的时候,我们会先定义一个信号,并获取它的发送器,然后给信号添加相应的观察者,最后通过发送器发送信号内容,观察者则可以收到信号并执行预设的函数体。从这个流程我们发现,如果要实现一次信号的传递,我们需要在绑定某个观察者之后,再发送信号,才能完成整个流程。SignalProducer的出现对这种模式做了改变: SignalProducer使得使用者在接受信号之前,预先定义信号发送者的发送函数,然后通过SignalProducer的Start系列函数来添加一个观察者,并内部调用发送函数,将发送者需要发送的内容传递给观察者。下面分别图绘Signal和SignalProducer的流程原理:
signal和signalproducer流程图
从流程图中,我们看到,Signal包含三大步骤:
- 创建
Signal。 - 添加观察者。
- 发送信号。
而SignalProducer中则包含两大步骤:
- 初始化
SignalProducer。 - 启动信号发生器。
本质上,两者做的时候事情是一样的,只不过,为了实用不同的场景,两者的使用方式有点差别。Signal的讲解在之前的文章中,这里就不赘述。本文主要讲解SignalProducer是怎么实现它的两道步骤的。
一、SignalProducer
基本的初始化方式:
使用一个Signal对象初始化
这个方法是使用一个
Siagnal来初始化一个信号发生器。实例:
这个方式将一个信号发生器和另一个信号关联,具体的做法比较复杂。主要是将外部的
Signal的一个观察者引用为SignalProducer内部Signal的发送器。这样,当外部的发生器的发送信号的时候, SignalProducer内部Signal的发送器作为它的一个观察者可以监听到这个信号,并作出反应,将信号发送给SignalProducer内部Signal所有的观察者。
SignalProducer的初始化方法有很多。除了public init(_ signal: Signal<Value, Error>) {}之外,其他的几乎都是通过SignalProducerCore的继承类来完成。
SignalProducerCore定义了三大方法:初始化函数,start函数,flatMapEvent函数,本文主要讲解初始化函数和start函数的实现原理。
SignalProducerCore
SignalProducerCore不会直接被使用,即是在内部也是,如果强制使用会造成致命错误导致程序崩溃。内部直接使用的是它的三个子类:
- SignalCore
- GeneratorCore
- TransformerCore
它们分别实现了父类SignalProducerCore的初始化方法和start.但是稍有差别。
二 、SignalCore初始化SignalProducer 和 Start启动SignalProducer原理
SignalCore初始化SignalProducer
以下是一个SignalCore使用的范例:
SignalProducer基本示例
范例中包含了信号的初始化和选择观察者并发送信号,这里包含了两步操作:初始化信号发生器(
SignalProducer)和开启信号发生器。
示例中,展示的是 SignalCore的初始化方法,这个方法直接由内部创建Signal对象并暴露该对象的发送器,我们在可以在SignalCore的源码中看到其内部包含了一个 _make属性,这个属性将保存SignalProducer中的初始化的内容。
SignalProducer使用SignalCore初始化:
SignalCore `初始化SignalProducer
可以看到,方法内部构件了一个Signal对象和其发送器observer;同时将传递进来的参数startHandler封装成了一个函数observerDidSetup,这个将在SignalProducer对象调用start系列的函数的时候调用,还有一个终结的函数interruptHandle。最终这些参数都被SignalProducerCore使用Instance结构体初始化其核心。
Instance结构体
然后SignalProducerCore 中将保存observerDidSetup在Instance的observerDidSetup中。以备在调用Start系列方法的时候调用。
基本原理就是,
SignalProducer在初始化的时候,将内部创建的Signal对象的发送器observer暴露出来了,我们可以在暴露的闭包中实现发送器的函数,最终这个函数被保存在SignalProducer的SignalCore中。
示例中,我对这个observer进行了处理,给它添加两次发送动作。实际上我们的发送器的操作应该在这里进行,不然,我们就没有办法使用SignalProducer的Start系列函数进行操作。
observer.send(value: 1)
observer.send(value: 2)
这个函数体内容实际上就是我们传给SignalProducer的startHandler函数体执行的内容。也即是在调用start系列的函数的时候会执行这部分的内容。SignalProducer是对Signal一种形式的封装,此时结合Signal的操作流程,可以知道SignalProducer的初始化函数内部定义了一个signal对象,并将这个signal的发送器需要发送的内容预设。这样的话,我们肯定需要再给这个Signal绑定观察者,并想办法执行发送器才能完成一个完整的信号发送流程,而这将是 SignalCore 的Start做的工作 。
SignalCore的Start方法
SignalCore源码
可以看到,在
SignalCore的初始化函数中,初始化后最终的Instance实际上被保存在SignalCore的一个属性 ---- 函数_make中。在调用Start函数的时候,_make被重新转化成一个Instance,在调用了Instance 的observerDidSetup之后,又执行了interruptHandle函数。一次SignalCore完整的信号发送流程就结束了。
三 、GeneratorCore初始化SignalProducer 和 Start启动SignalProducer原理
GeneratorCore的初始化建立在SignalCore之上。
GeneratorCore源码
GeneratorCore源码源码中,用一个
generator属性保存了GeneratorCore初始化时的尾随闭包。下面以
SignalProducer其中一个出初始化函数为例:
这个函数通过GeneratorCore函数初始化,并在初始化中直接对函数暴露的
Observer进行了实现:
observer.send(value: value)
observer.sendCompleted()
这部分内容被保存在GeneratorCore的 generator属性中。
而后,整个GeneratorCore对象被SignalCore用来初始化,并将GeneratorCore对象保存到SignalCore的Instance中。这其实是进一步对信号源的封装,除了Signal在内部创建之外,Signal的发送器也在内部进行实现。
初始化之后,我们可以照常使用Start系列函数进行呼唤调用。
在GeneratorCore的Start的源码中,我们看到其中调用了其generator函数,但是在此之前,预先调用了observerGenerator(d)函数,这样做的目的是要先创建一对 Signal和Observer,然后将Observer在generator的实现(Send())调用,最终完成Signal的三步流程。
除了以上几个例子之外,SignalProducer 还有很多个初始化的方式,start系列的方法也繁多。但总归是通过本文例子中的基础方法实现的。