Swift见解

ReactiveCocoa - Swift 解读系列三:Sign

2017-11-20  本文已影响27人  BennyLoo

SignalProducer是RAS对Signal的封装。之前我们使用Signal的时候,我们会先定义一个信号,并获取它的发送器,然后给信号添加相应的观察者,最后通过发送器发送信号内容,观察者则可以收到信号并执行预设的函数体。从这个流程我们发现,如果要实现一次信号的传递,我们需要在绑定某个观察者之后,再发送信号,才能完成整个流程。SignalProducer的出现对这种模式做了改变: SignalProducer使得使用者在接受信号之前,预先定义信号发送者的发送函数,然后通过SignalProducerStart系列函数来添加一个观察者,并内部调用发送函数,将发送者需要发送的内容传递给观察者。下面分别图绘SignalSignalProducer的流程原理:

signal和signalproducer流程图

从流程图中,我们看到,Signal包含三大步骤:

  1. 创建Signal
  2. 添加观察者。
  3. 发送信号。

SignalProducer中则包含两大步骤:

  1. 初始化SignalProducer
  2. 启动信号发生器。
    本质上,两者做的时候事情是一样的,只不过,为了实用不同的场景,两者的使用方式有点差别。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不会直接被使用,即是在内部也是,如果强制使用会造成致命错误导致程序崩溃。内部直接使用的是它的三个子类:

它们分别实现了父类SignalProducerCore的初始化方法和start.但是稍有差别。

二 、SignalCore初始化SignalProducerStart启动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暴露出来了,我们可以在暴露的闭包中实现发送器的函数,最终这个函数被保存在SignalProducerSignalCore 中。

示例中,我对这个observer进行了处理,给它添加两次发送动作。实际上我们的发送器的操作应该在这里进行,不然,我们就没有办法使用SignalProducerStart系列函数进行操作。

            observer.send(value: 1)
            observer.send(value: 2)  

这个函数体内容实际上就是我们传给SignalProducer的startHandler函数体执行的内容。也即是在调用start系列的函数的时候会执行这部分的内容。SignalProducer是对Signal一种形式的封装,此时结合Signal的操作流程,可以知道SignalProducer的初始化函数内部定义了一个signal对象,并将这个signal的发送器需要发送的内容预设。这样的话,我们肯定需要再给这个Signal绑定观察者,并想办法执行发送器才能完成一个完整的信号发送流程,而这将是 SignalCoreStart做的工作 。

SignalCoreStart方法
SignalCore源码
可以看到,在SignalCore的初始化函数中,初始化后最终的Instance实际上被保存在SignalCore的一个属性 ---- 函数_make中。在调用Start函数的时候,_make被重新转化成一个Instance,在调用了Instance 的observerDidSetup之后,又执行了interruptHandle函数。一次SignalCore完整的信号发送流程就结束了。

三 、GeneratorCore初始化SignalProducerStart启动SignalProducer原理

GeneratorCore的初始化建立在SignalCore之上。

GeneratorCore源码
GeneratorCore源码源码中,用一个 generator属性保存了GeneratorCore初始化时的尾随闭包。
下面以SignalProducer其中一个出初始化函数为例:

这个函数通过GeneratorCore函数初始化,并在初始化中直接对函数暴露的Observer进行了实现:
observer.send(value: value)
observer.sendCompleted()

这部分内容被保存在GeneratorCoregenerator属性中。
而后,整个GeneratorCore对象被SignalCore用来初始化,并将GeneratorCore对象保存到SignalCore的Instance中。这其实是进一步对信号源的封装,除了Signal在内部创建之外,Signal的发送器也在内部进行实现。
初始化之后,我们可以照常使用Start系列函数进行呼唤调用。
GeneratorCoreStart的源码中,我们看到其中调用了其generator函数,但是在此之前,预先调用了observerGenerator(d)函数,这样做的目的是要先创建一对 SignalObserver,然后将Observer在generator的实现(Send())调用,最终完成Signal的三步流程。

除了以上几个例子之外,SignalProducer 还有很多个初始化的方式,start系列的方法也繁多。但总归是通过本文例子中的基础方法实现的。

上一篇下一篇

猜你喜欢

热点阅读