ReactiveCocoa源码解读(一)

本着饮水思源的想法,面对ReactiveCocoa的强大功能,按捺不住心中的好奇心,于是走进其源码之中,一探ReactiveCocoa的魅力所在。虽然,耳闻其强大功能的核心是:信号,但一直不知道这个信号是如何产生、如何传递,又是如何被处理的。曾经以为信号传递是通知,但是真正读了源码后,才发现之前的想法有多不妥,而人家的实现又是多巧妙。

本文主要从ReactiveCocoa的主要类入手,通过剖析其整个应用过程中,信号的生命周期来领略其编程之美。

一、RACSignal

1. 应用:

2.源码实现

  • 创建信号

+(RACSignal *)createSignal:(RACDisposable * (^)(id<RACSubscriber> subscriber))didSubscribe;

  • 订阅信号

(RACDisposable *)subscribeNext:(void (^ )(id x))nextBlock;

  • 发送信号

[subscriber sendNext:@1]

3.流程图

RACSignal

4.总结

先创建信号,然后订阅信号,最后执行didSubscribe内部的方法,顺序是不能变的

RACSignal底层实现

二、RACSubject

1. 应用

2.源码实现

  • 创建信号

  • 订阅信号

RACSubject订阅信号的实质就是将内部创建的订阅者保存在订阅者数组self.subscribers中,仅此而已。订阅者对象有一个名为nextBlock的block参数

  • 发送信号

3.流程图

RACSubject

4.总结

RACSubscriber:表示订阅者的意思,用于发送信号,这是一个协议,不是一个类,只要遵守这个协议,并且实现方法才能成为订阅者。通过create创建的信号,都有一个订阅者,帮助他发送数据。

RACDisposable:用于取消订阅或者清理资源,当信号发送完成或者发送错误的时候,就会自动触发它。

RACSubject的底层与RACSignal不一样:

  • 调用subscribeNext订阅信号,只是把订阅者保存起来,并且订阅者的nextBlock已经赋值了
  • 调用sendNext发送信号,遍历刚刚保存的所有订阅者,一个一个调用订阅者的nextBlock
  • 由于本质是将订阅者保存到数组中,所以可以有多个订阅者订阅信息。

必须先订阅,后发送信息。订阅信号就是创建订阅者的过程,如果不先订阅,数组中就没有订阅者对象,那就通过订阅者发送消息

三、RACReplaySubject

1.应用

RACReplaySubject即可以先订阅后发送信号,也可以反过来

2.源码实现

  • 创建信号

  • 订阅信号

  • 发送信号

3.原理图

RACReplaySubject

4.总结

RACReplaySubjectRACSubject的子类
由于每次发送信号时,会先保存nextBlock,然后调用父类的sendNext方法,遍历订阅者,执行信号;而每次订阅信号时,会从valuesReceived中取值,然后调用sendNext方法,遍历订阅者,执行信号。所以,订阅和发送没有先后顺序。


未完待续 ……

感觉不错,打个赏?
微信                                 支付宝
pay_weixin            pay_zhifubao
金额随意 快来“”我呀~
联系方式:kelvin@fishbay.cn

发表评论

电子邮件地址不会被公开。 必填项已用*标注