前文：http://www.jianshu.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;
}

1. 该方法创建了一个RACMulticastConnection对象，并给了本身信 号和传递信号一个别名。
2. 将RACMulticastConnection的两个属性指向连接的两个信号。
3. 将后传入的信号作为原始的信号（也就是那个冷信号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框架的冷热信号进行深入处理