MyException - 我的异常网
当前位置:我的异常网» Swift » ReactiveSwift源码解析(7) Signal的CombineLatest的

ReactiveSwift源码解析(7) Signal的CombineLatest的代码实现

www.MyException.Cn  网友分享于:2013-08-09  浏览:0次
ReactiveSwift源码解析(七) Signal的CombineLatest的代码实现

本篇博客我们就来聊一下combineLatest()的使用以及具体的实现方式。在之前的《iOS开发之ReactiveCocoa下的MVVM》的博客中我们已经聊过combineLatest()的用法,虽然是使用老版本的ReactiveCocoaObjective-C语言介绍的,不过使用原理上都是一致的。都是将两个信号量进行合并,当其中一个信号量发出Value事件时,如果另一个信号量之前也发送过Value事件,那么就取出最后一个事件的Value值与当前发送的事件值进行合并,然后将合并后的值发送给新的信号量的观察者。如果其中一个未发送过任何Value,那么将不会向合并后的信号量的观察者发送事件。下方会进行详细的叙述。

下面我们就来仔细的聊一下combineLatest()的使用方式、具体的代码实现以及合并信号量的工作原理。下方的使用示例我们还是与《iOS开发之ReactiveCocoa下的MVVM》这篇博客中聊combineLatest()时使用是示例相同,只不过我们是使用的Swift语言写的,详情如下。

 

一、combineLatest()使用

下方代码片段是combineLatest()使用方式,介绍如下:

  • 首先创建两个信号量,一个是signalString,用来发送Value值为String类型的信号。另一个是signalInt,用来发送Value值为Int类型的信号。
  • 调用信号量signalString的combineLatest()方法,将signalString信号量最后发送的值与信号量signalInt最后发送的值进行合并。然后将合并后的元组(String, Int)发送给新创建的combineLatestSignal信号量的所有观察者。
  • 接着就是调用signalStringsignalInt所对应的observer对象来发送Value事件了。

从输出结果我们不难看出,无论是signalString信号量还是signalInt信号量发出的Value消息,只要是另一个信号量的LastValue不为nil。那么新的信号量combineSignal的观察者就会收到相应的合并后的值,如下具体结果如下所示:

  

 

针对上述的示例,我们画了下方的简图来说明合并信号量的工作方式。LettersNumber是两个信号量,Combine是两者通过combineLatest()方法生成的新的信号量,然后LettersNumber信号量就随机发送消息。Combine信号量根据LetterNumbers发送值的情况进行信号量的输出。具体如下所示。

  

 

 

二、combineLatest()的具体代码实现

接下来我们就来看一下combineLatest()代码的具体实现。下方就是该方法对应的核心代码:

  • 首先下方这个泛型函数的参数是一个信号量,而返回值是一个新的信号量,而这个新的信号量的类型是一个可以接受元组的信号量。而这个元组中的两个值就是这两个信号量最后一个值合并而成的。
  • 其次创建了一个NSLock类型的锁,用来保证多线程下的原子性操作。
  • 定义声明两个常量对象,用来存储两个合并信号量最后发送的值。CombineLatestState<Value>类的实现是比较简单的,目的就是为了暂存信号量最后发出的值。
  • 然后有定义了一个无参闭包onBothValue, 而这个闭包体中所做的事情是像新生成的合并信号量发送合并后的元组消息。这样,与新信号量所关联的观察者Observer就会收到这个元组。
  • 紧接着就是创建了一个新的代理观察者observerDelegate, 用来代理新信号量的Observer来发送各种事件。而这个observerDelegate代理观察者是代替合并后的新信号量发送事件的。
  • 最后要做的就是将observerDelegate与要合并的两个信号量进行整合关联,使得要合并的两个信号量中的任何一个信号量发出事件时。在两者都有LatestValue的情况下,这个新合并的信号量所绑定的观察者都可以接收到该事件。

具体代码如下所示:

  

 

下方这个方法就负责将新的信号量的发送事件的Observer与之前信号量进行整合。具体做法就是往之前的信号量的Bag容器中添加一个新的观察者Observer,在这个新的观察者处理Event事件时,调用ObserverDelegate的相关事件即可。

  

 

在上述代码中,我们对暂存之前两个信号量最后发出的值的signalStateotherState进行了相关信息的打印。先打印了hashValue,然后打印了其暂存的值。当着两个对象中的latestValue皆不为空时,那么就调用observerDelegatesendValue方法执行onBothValue闭包,向合并信号量所有的Observer发送元组消息即可

下方就是对signalState和otherState的相关信息进行的打印 ,从打印信息中我们可以看出,尽管在observerWithState()函数中是以参数的形式获取的signalState和otherState,但是其内存地址是不变的,独一份。而且当这两个都有lastestValue的情况下,合并信号量的观察者才会收到相应的Value事件。具体如下所示。

  

 

 

 三、Latest合并原理图

针对上述的代码实现,以及参考之前博客中原理图的形式,于是乎我们给出了下方的这个原理图。原理图应该是清晰明了,一目了然的,在此就不做过多的赘述了。通过下图的结构,我们不难看出,combineLatestSignal信号量仍然是可以进行链式发展的。

 

 

在Signal.swift文件中关于SignalProtocol的扩展的方法中,基本上是按照上述的套路来扩展的。大体就是一个方法返回一个新的信号量,这个新的信号量与原始信号量间通过桥接信号量来进行关联。不同的方法在处理原信号量往新的信号量发送事件时,在中间所做的事情不同。Signal.swift文件中还有好多类似的方法,在此就不一一进行介绍了,如果你对某个方法的实现感兴趣,可以采用上述的套路来进行解析。

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

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

1楼大哥的大哥
膜,大神厉害。。。产量好高

文章评论

程序员应该关注的一些事儿
程序员应该关注的一些事儿
60个开发者不容错过的免费资源库
60个开发者不容错过的免费资源库
我的丈夫是个程序员
我的丈夫是个程序员
一个程序员的时间管理
一个程序员的时间管理
聊聊HTTPS和SSL/TLS协议
聊聊HTTPS和SSL/TLS协议
什么才是优秀的用户界面设计
什么才是优秀的用户界面设计
代码女神横空出世
代码女神横空出世
2013年中国软件开发者薪资调查报告
2013年中国软件开发者薪资调查报告
中美印日四国程序员比较
中美印日四国程序员比较
Java程序员必看电影
Java程序员必看电影
做程序猿的老婆应该注意的一些事情
做程序猿的老婆应该注意的一些事情
程序员都该阅读的书
程序员都该阅读的书
Java 与 .NET 的平台发展之争
Java 与 .NET 的平台发展之争
5款最佳正则表达式编辑调试器
5款最佳正则表达式编辑调试器
程序员的鄙视链
程序员的鄙视链
写给自己也写给你 自己到底该何去何从
写给自己也写给你 自己到底该何去何从
“肮脏的”IT工作排行榜
“肮脏的”IT工作排行榜
程序员周末都喜欢做什么?
程序员周末都喜欢做什么?
程序员和编码员之间的区别
程序员和编码员之间的区别
我是如何打败拖延症的
我是如何打败拖延症的
团队中“技术大拿”并非越多越好
团队中“技术大拿”并非越多越好
那些性感的让人尖叫的程序员
那些性感的让人尖叫的程序员
10个调试和排错的小建议
10个调试和排错的小建议
如何区分一个程序员是“老手“还是“新手“?
如何区分一个程序员是“老手“还是“新手“?
老美怎么看待阿里赴美上市
老美怎么看待阿里赴美上市
科技史上最臭名昭著的13大罪犯
科技史上最臭名昭著的13大罪犯
程序员眼里IE浏览器是什么样的
程序员眼里IE浏览器是什么样的
那些争议最大的编程观点
那些争议最大的编程观点
每天工作4小时的程序员
每天工作4小时的程序员
程序猿的崛起——Growth Hacker
程序猿的崛起——Growth Hacker
Google伦敦新总部 犹如星级庄园
Google伦敦新总部 犹如星级庄园
程序员最害怕的5件事 你中招了吗?
程序员最害怕的5件事 你中招了吗?
初级 vs 高级开发者 哪个性价比更高?
初级 vs 高级开发者 哪个性价比更高?
“懒”出效率是程序员的美德
“懒”出效率是程序员的美德
要嫁就嫁程序猿—钱多话少死的早
要嫁就嫁程序猿—钱多话少死的早
不懂技术不要对懂技术的人说这很容易实现
不懂技术不要对懂技术的人说这很容易实现
亲爱的项目经理,我恨你
亲爱的项目经理,我恨你
我跳槽是因为他们的显示器更大
我跳槽是因为他们的显示器更大
总结2014中国互联网十大段子
总结2014中国互联网十大段子
漫画:程序员的工作
漫画:程序员的工作
当下全球最炙手可热的八位少年创业者
当下全球最炙手可热的八位少年创业者
鲜为人知的编程真相
鲜为人知的编程真相
10个帮程序员减压放松的网站
10个帮程序员减压放松的网站
老程序员的下场
老程序员的下场
为啥Android手机总会越用越慢?
为啥Android手机总会越用越慢?
如何成为一名黑客
如何成为一名黑客
 程序员的样子
程序员的样子
旅行,写作,编程
旅行,写作,编程
编程语言是女人
编程语言是女人
软件开发程序错误异常ExceptionCopyright © 2009-2015 MyException 版权所有