RAC(ReactiveCocoa)介绍(十)——RACMult
2018-06-02 本文已影响601人
我只不过是出来写写代码
在实际项目开发过程中,经常会在多处不同地方对同一信号进行订阅。比如:在网络请求时,收到返回数据要针对页面多处进行更新操作。
通常会出现以下RAC写法:

这样的错误写法打印结果如下:

从打印结果来看,很明显地RACSignal拥有两个订阅者时,发送信号与销毁信号都执行了两次。当拥有更多订阅者或者需要在发送信号前耗时处理时,这种写法大大降低了运行效率,浪费了不必要的资源。
针对这种情况,就需要使用
RACMulticastConnection
来处理。将上述问题代码加入进
RACMulticastConnection
处理之后
这时再查看打印结果

发送信号时只执行了一次,两个订阅者都收到了各自的订阅信号。
为什么RACMulticastConnection
可以实现一次发送多处订阅者就可以收到信号?
带着问题去查看其内部实现过程

从上图代码实现中,可以发现
RACMulticastConnection
是基于RACSubject
来实现的,并将RACSubject
封装成了RACMulticastConnection
对象。打印connection.signal
,可以发现是为RACSubject
类的对象。再继续进入至
- (instancetype)initWithSourceSignal:(RACSignal *)source subject:(RACSubject *)subject
方法中。
此处使用了方法
bool OSAtomicCompareAndSwap32Barrier( int32_t __oldValue, int32_t __newValue, volatile int32_t *__theValue );
用于将
_hasConnected
与0(oldValue)
进行比较,如果两者是匹配的,则方法结果返回YES并将_hasConnected
赋值为1(newValue)
。即由未连接状态,修改成已连接状态。当由未连接状态变为已连接状态时,执行信号的订阅方法。
总结一下RACMulticastConnection实现过程:
1.创建connect
,connect.sourceSignal
-> RACSignal(原始信号) connect.signal
-> RACSubject
2.订阅connect.signal
,会调用RACSubject
的subscribeNext
,创建订阅者,而且把订阅者保存起来,不会执行block。
3.[connect connect]
内部会订阅RACSignal(原始信号)
,并且订阅者是RACSubject
4.RACSubject
的sendNext
,会遍历RACSubject
所有订阅者发送信号,并执行他们的nextBlock( )