ReactiveSwift源码解析(八) SignalProducer的代码的基本实现

在前面几篇博客中我们详细的聊了ReactiveSwift中的Bag、Event、Observer以及Signal的使用方式和代码实现。那么在接下来的这几篇博客中,我们就依附于之前博客的基础上来聊一聊SignalProducer的用法以及内部的代码实现。从SignalProducer的名字中,我们容易知道,SignalProducer是信号量的生产者,确切的说,SignalProducer基于Signal的又一层封装。扩充了Signal的使用方式,使其更贴近于一些业务场景,比如网络的请求等。

接下来我们看一下SignalProducer的基本实现,也就是看一下SignalProducer一些核心的构造器和核心的方法。并且给出这些构造器以及核心方法的代码解释并给出其对应的使用方式。

一、SignalProducer的核心属性、方法和构造器

开门见山,在本篇博客的第一部分我们先给出SignalProducer结构体的核心属性、构造器和方法。下方会对这些SignalProducer的核心内容进行介绍,然后再看一下其具体的使用和运行方式。之所以说本部分所介绍的内容是SignalProducer的核心,因为SignalProducer的其他方法、构造器是在下方所要介绍的内容的基础上所建立起来的。

1、startHandler属性、init(startHandler)构造器以及startWithSignal()的方法实现

startHandler属性是SignalProducer结构体的基本实现中的唯一属性。从下方代码片段中我们可以看出startHandler的类型是一个闭包类型。该闭包类型的的参数是ObserverDisposable类型的对象,返回值为空。

而紧接着下方的init(startHandler)构造器就是为startHandler属性赋值的。虽然该init(startHandler)构造方法简单,但是是SignalProducer结构体的核心,因为在SignalProducer其他构造器中直接或者间接调用了下方的构造方法,稍后我们会给出相应的代码实现。 

上述代码片段中的startWithSignal(setup)方法,也是SignalProducer结构体中比较核心的方法。因为在SignalProducer结构体的扩展方法中直接或者间接的调用了该方法。该方法中做的事情比较单一,就是调用Signal的pipe()方法创建了一个signal对象与该对象所对应的observer对象。该方法的参数是一个名为setup的闭包,将创建的signal对象交给setup()闭包,将observer对象交给startHandler()闭包。而startHandler的闭包体就是init(startHandler)构造器的尾随闭包。

2、上述属性和方法的使用

上述的属性和方法之所以是SignalProducer结构体的核心,是因为SignalProducer的其他构造器以及扩展方法都是在此基数上构建起来的,稍后我们会介绍到。现在我们来看一下上述方法的调用方式。下方就是我们给出的针对上述方法的示例和输出结果。

  • 首先调用了SignalProducer的init(startHandler)构造器,创建了一个producer常量。在该构造器的尾随闭包中,我们可以通过闭包回调的形式获取到producer中signal对象所对应的observer,我们可以通过该对象发送一些值,如下所示。
  • 然后我们创建了一个Observer类的subscribe1对象,并给出了该观察者的Value事件的处理闭包。
  • 最后我们调用startWithSignal启动producer的信号量,通过startWithSignal()方法的尾随闭包,我们可以获取到producer中的signal对象,然后将我们创建的subscriber观察者与该signal进行关联。关联后,subscriber或收到producer中的observer对象所发送的Value事件。

最下方就是该段代码的运行结果,如下所示。

二、SignalProducer中的其他构造器

上面我们聊了SignalProducer的核心构造器,在SignalProducer结构体的构造器阵营中,其构造器都是在上述核心构造器的基础上衍生出来的快捷构造器。这些衍生出来的构造器适用于特定场景下的SignalProducer的初始化,其功能更为专一,使用更为便捷。接下来我们就来介绍一下这些衍生构造器的代码实现以及使用方式。

1、init(signal)和init(value)

下方代码片段就是init(signal)和init(value)的具体实现,从下方代码片段中我们容易看出,最终都是调用的上述我们介绍的init(startHandler)这个构造器。只不过在startHandler这个闭包块中所做的事情不同罢了。

我们先来看init(signal),该构造器接收一个signal信号量,然后将producer中的observer对象添加为该参数signal信号量的观察者,也就是说当这个信号量发送消息是,producer中的observer会收到这个外部信号量发过来的消息,然后通知producer中内部的信号量的所有观察者。针对上述代码实现我们可以画出下方的简图。左边的mySignal就是通过init(signal)构造器传过来的信号量对象,mySignal信号量中的Bag中存储了一些该信号量的观察者。然后调用SignalProducerinit(signal)方法将mySignal信号量传给SignalProducer,然后将SignalProducer中的内部信号量signal所对应的observe添加到mySignalBag中,使其成为mySignal信号量的观察者。具体如下所示,稍后我们会给出具体使用方式。

上述init(value)构造器就简单的多了,就是在调用init(startHandler)构造器的尾随闭包中调用SignalProducer内部的observer将init(value)提供的参数发送出去。发送完毕后就调用Observer的sendCompleted()方法,完成信号量的发送。

接下来我们来看一下上述两个构造器的使用示例以及示例的运行结果。

  • 首先我们来看一下init(signal)的使用示例。首先创建了一个mySignal信号量以及该信号所对应的myObserver。然后调用init(signal)构造器,并把mySignal对象传给该构造器。接着通过startWithSignal()方法往producer中的signal中添加一个名为subscriber1观察者。然后调用myObserver发送Value信号量,我们能看到,producer中信号量的观察者subscriber1也能收到该信号量。
  • 而init(value)构造器的使用就简单许多,直接在SignalProducer创建时,将SignalProducer所对应的信号量所需要发送的值传进去即可,如下所示。

2、init(action)、init(error)以及init(result)构造器

接下来我们再来看一下这init(action)、init(error)以及init(result)三个构造器,这个三个构造器也是直接或者间接的调用了我们之前的核心构造器init(startHandler)。下方就是这三个构造器的具体代码实现:

  • init(action)构造器接收了一个名为action的无参闭包,该闭包的返回值为Value。从其代码实现我们不难看出,下方代码就等同于self.init(value: action())。action闭包的作用就是为observer.send(value)提供值的。
  • init(error)构造器中就是在调用init(startHandler)时,在其尾随闭包中的获取到observer然后调用send(error)方法,发送Failure事件。
  • init(result)构造器接收的是一个Result枚举对象,目的就是将Result枚举中的success转换成Value事件,将failure结果转换成failure事件并发送相应的Error。

因为该三个构造方法比较简单,就不提供相应的使用示例了,如果你感兴趣,可以在官方提供的Playground中进行示例的编写。

3、init(values)和init(first, second, tail…)构造器

本小节我们就来聊一下init(values)和init(first, second, tail)这两个构造器,这两个构造器的功能其实差不多,实现方式也是相同的,只不过是调用方式不同。下方是这两个构造器具体的代码实现。

  • init(values)构造器接收的是一个可遍历的序列,在具体的代码实现中,我们遍历该序列,取出其中的每个值,然后调用observer的send(value)方法将该值进行发送。遍历完成后,调用了sendCompleted()方法完成信号量的发送。
  • init(first, second, tail ...)构造器是一个不定参构造器。在该构造器中,我们将收到的参数组合成数组,然后调用init(values)构造器,具体实现如下。

针对上述的构造器,我们给出了下方这两个使用示例,以及相应示例的输出结果。

今天的博客就先到这儿,下篇博客我们会继续解析ReactiveSwift框架中的其他内容。

上述代码github分享地址:https://github.com/lizelu/TipSwiftForRac

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏喵了个咪的博客空间

zephir-(8)类和对象1

#zephir-类和对象1# ? ##前言## 先在这里感谢各位zephir开源技术提供者 zephir全面使用对象编程,这就是为什么拓展的使用方式只能是方法和...

2853
来自专栏技术记录

通讯协议序列化解读(一) Protobuf详解教程

前言:说到JSON可能大家很熟悉,是目前应用最广泛的一种序列化格式,它使用起来简单方便,而且拥有超高的可读性。但是在越来越多的应用场景里,JSON冗长的缺点导致...

1171
来自专栏架构说

声明和定义的区别(深入理解)

问题 声明和定义区别 definition declared 微信排版支持makdown语法不友好 可以查看原文链接 先看一下 例子1 编译有没有问题? cl...

27110
来自专栏Kirito的技术分享

警惕不规范的变量命名

就在最近,项目组开始强调开发规范了,今天分享一个变量名命名不规范的小案例,强调一下规范的重要性。 Boolean变量名命名规范 16年底,阿里公开了《Java...

3389
来自专栏轮子工厂

一篇文章帮你解决中文乱码问题---JavaWeb中文编码问题全面解析

这就是为什么我们在浏览器的地址栏中能看到中文,但是把地址拷贝出来后中文就变成了一些奇怪的串了。

7174
来自专栏大闲人柴毛毛

Java异常体系中的秘密

相信大家每天都在使用Java异常机制,也相信大家对try-catch-finally执行流程烂熟于胸。本文将介绍Java异常机制的一些细节问题,这些问题虽然很...

36310
来自专栏desperate633

深入理解Java多线程中的volatile关键字Java 的 volatile关键字对可见性的保证Java 的 volatile关键字在保证可见性之前的所做的事情Volatile有时候也是不够的什么时

Java关键字用于将一个变量标记为“存储在内存中的变量”。更准确的说,意思就是每一次对volatile标记的变量进行读取的时候,都是直接从电脑的主内存进行的,而...

983
来自专栏技术记录

通讯协议序列化解读(一) Protobuf详解教程

前言:说到JSON可能大家很熟悉,是目前应用最广泛的一种序列化格式,它使用起来简单方便,而且拥有超高的可读性。但是在越来越多的应用场景里,JSON冗长的缺点导致...

984
来自专栏大内老A

yield在WCF中的错误使用——99%的开发人员都有可能犯的错误[上篇]

在定义API的时候,对于一些返回集合对象的方法,很多人喜欢将返回类型定义成IEnumerable<T>,这本没有什么问题。这里要说的是另一个问题:对于返回类型为...

1818
来自专栏Java帮帮-微信公众号-技术文章全总结

Java面试系列8

? 一、heap和stack有什么区别 栈是一种线形集合,其添加和删除元素的操作应在同一段完成。 栈按照后进先出的方式进行处理。 堆是栈的一个组成元素 ...

3075

扫码关注云+社区

领取腾讯云代金券