前文：//www.greatytc.com/p/6348148643f6
上篇文章说到了冷热信号和副作用, 但是副作用针对与冷信号有什么影响，本文将进行排坑。
如下:
@weakify(self);
RACSignal *signal = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
NSLog(@"执行");
@strongify(self)
[self.companyApi getCollectionWithCompanyID:1 success:^(id response) {
[subscriber sendNext:response];
[subscriber sendCompleted];
} fail:^(NSInteger httpCode, NSString *msg) {
[subscriber sendError:[NSError errorWithDomain:@"HttpFail" code:httpCode userInfo:@{@"msg":msg}]];
[subscriber sendCompleted];
}];
return [RACDisposable disposableWithBlock:^{
[self.companyApi cancelRequest];
}];
}];
RACSignal *collectionBtnSignal = [signal map:^id(id value) {
if ([value[@"status"] integerValue]) {
return @(YES);
} else {
return @(NO);
}
}];
RACSignal *collectionLSignal = [signal map:^id(id value) {
if ([value[@"status"] integerValue]) {
return @"收藏";
} else {
return @"未收藏";
}
}];
RAC(collectionL, text) = collectionLSignal;
RAC(collectionBtn, selected) = collectionBtnSignal;
如果复制代码看现象的话会注意到signal被订阅了两次，也被执行了两次，一个label和一个btn都同时变相的订阅了signal。而我们知道冷信号的特点就是无论什么时间订阅，订阅者都会发送之前的消息，这也导致了增加了网络请求次数。也许这个例子也许你已经用到了只不过你还没有发现，有可能在你们的二级列表塞选中，多个组件用到同一个接口，如果利用冷信号请求数据，那就会出现这样的影响。（热信号与副作用没有影响，主要针对与他们的触发时机）
冷排坑
上面说到了副作用对于冷信号的影响，那么接下来说下怎么修改如上的代码吧。
替换冷信号
开发人员可以利用如信号进行请求，RACSubject及其子类RACReplaySubject来进行请求通知。或者利用RACCommand来进行，后边会说到用法
利用RACSignal的Category(Operations)
RAC框架给出了5种方法进行冷信号转换热信号，从本质上讲，其实按道理来说都是替换。五种方法如下：
/// Creates and returns a multicast connection. This allows you to share a single
/// subscription to the underlying signal.
- (RACMulticastConnection *)publish;
/// Creates and returns a multicast connection that pushes values into the given
/// subject. This allows you to share a single subscription to the underlying
/// signal.
- (RACMulticastConnection *)multicast:(RACSubject *)subject;
/// Multicasts the signal to a RACReplaySubject of unlimited capacity, and
/// immediately connects to the resulting RACMulticastConnection.
///
/// Returns the connected, multicasted signal.
- (RACSignal *)replay;
/// Multicasts the signal to a RACReplaySubject of capacity 1, and immediately
/// connects to the resulting RACMulticastConnection.
///
/// Returns the connected, multicasted signal.
- (RACSignal *)replayLast;
/// Multicasts the signal to a RACReplaySubject of unlimited capacity, and
/// lazily connects to the resulting RACMulticastConnection.
///
/// This means the returned signal will subscribe to the multicasted signal only
/// when the former receives its first subscription.
///
/// Returns the lazily connected, multicasted signal.
- (RACSignal *)replayLazily;
其中核心方法是- (RACMulticastConnection *)multicast:(RACSubject *)subject; 其余都是对于这个方法的封装。接下来我们看下他的使用和实现。
使用方法就简单介绍了，通过multicast创建一个RACMulticastConnection信号连接类，实现订阅在连接还是先连接在订阅取决与你们的业务也取决于multicast传入的信号类型，假如传入RACSubject那么和RACSubject用法一样只能接受到订阅以后的信号，如传入RACReplaySubject则支持接受所有信号
RACMulticastConnection *connection = [signal multicast:[RACSubject subject]];
[connection.signal subscribeNext:^(id x) {
NSLog(@"+base:%@", x);
}];
[connection connect];
下面我们分析下源码的实现
Category的方法
- (RACMulticastConnection *)multicast:(RACSubject *)subject {
[subject setNameWithFormat:@"[%@] -multicast: %@", self.name, subject.name];
RACMulticastConnection *connection = [[RACMulticastConnection alloc] initWithSourceSignal:self subject:subject];
return connection;
}
RACMulticastConnection：
- (id)initWithSourceSignal:(RACSignal *)source subject:(RACSubject *)subject {
NSCParameterAssert(source != nil);
NSCParameterAssert(subject != nil);
self = [super init];
if (self == nil) return nil;
_sourceSignal = source;
_serialDisposable = [[RACSerialDisposable alloc] init];
_signal = subject;
return self;
}
- (RACDisposable *)connect {
BOOL shouldConnect = OSAtomicCompareAndSwap32Barrier(0, 1, &_hasConnected);
if (shouldConnect) {
self.serialDisposable.disposable = [self.sourceSignal subscribe:_signal];
}
return self.serialDisposable;
}
- 该方法创建了一个RACMulticastConnection对象，并给了本身信 号和传递信号一个别名。
- 将RACMulticastConnection的两个属性指向连接的两个信号。
- 将后传入的信号作为原始的信号（也就是那个冷信号signal）的订阅者。
可能是第三步有些绕，在我们的印象里订阅者专属于一个类：RACSubscriber，但实际上订阅者只是一个遵守id<RACSubscriber>的对象即可,这里也可以看到面向协议编程的灵活性。subject父子都是签署了RACSubscriber协议所以他们都可以作为订阅者。
连接信号类如何替换的信号？
其实使整体替换掉了原有的冷信号。connect方法好比是冷信号的订阅方法，产生了回掉，而冷信号创建回掉block的方法实际传入的是热信号，热信号中必然包含了多个订阅者的数组。而连接类实际订阅的是热信号的订阅。一系列操作下来其实连接类本质就是热信号替换了你的冷信号。
其余的方法
// 外部引用RACMulticastConnection使用Racsubject替换冷信号
- (RACMulticastConnection *)publish;
// 内部引用RACMulticastConnection使用RacReplaySubject替换冷信号，并对冷信号订阅
- (RACSignal *)replay;
// 内部引用RACMulticastConnection使用RacReplaySubject替换冷信号，只回掉最后一个信号
- (RACSignal *)replayLast;
// 本质与replay无区别，只有使用替换热信号订阅时的时候才会调用connect方法
- (RACSignal *)replayLazily;
最后
也许你在日常的开发过程中没有遇见冷热信号的问题，但是通过这两篇文章的阅读可以让你对rac框架面向协议编程和一些方法的灵活使用，如果自己写一大部分伪代码更能对于这个框架进行深入的学习。最后如果你碰见你点击一个收藏按钮出现了收藏两次或n次的问题，请记住rac框架的冷热信号进行深入处理
