文章系列
《RACSignal 》
《RACDisposable》
《RACSubject、RACReplaySubject》
《iOS RAC - 基本用法》
《iOS RAC - 定时器》
《iOS RAC - RACMulticastConnection》
《iOS RAC - RACCommand》
《iOS RAC - 核心方法bind》
《iOS RAC - 集合RACTuple、RACSequence》
《iOS RAC - rac_leftSelector》
《iOS RAC - 映射》
《iOS RAC - 过滤》
《iOS RAC - 登录页面，MVVM》

git地址

一、使用

在项目中我们一般都会涉及网络请求，在使用RAC进行网络请求的时候我们可以这样子写：

    RACSignal * signal = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
        NSLog(@"发送网络请求");
        
        [subscriber sendNext:@"得到网络请求数据"];
        
        return nil;
    }];
    
    [signal subscribeNext:^(id x) {
        NSLog(@"1 - %@",x);
    }];
    
    [signal subscribeNext:^(id x) {
        NSLog(@"2 - %@",x);
    }];
    
    [signal subscribeNext:^(id x) {
        NSLog(@"3 - %@",x);
    }];

我们先运行一次看看log打印就知道问题所在了。

2017-10-26 14:40:36.765947+0800 RAC[816:321538] 发送网络请求
2017-10-26 14:40:36.766137+0800 RAC[816:321538] 1 - 得到网络请求数据
2017-10-26 14:40:36.766388+0800 RAC[816:321538] 发送网络请求
2017-10-26 14:40:36.766503+0800 RAC[816:321538] 2 - 得到网络请求数据
2017-10-26 14:40:36.766725+0800 RAC[816:321538] 发送网络请求
2017-10-26 14:40:36.766857+0800 RAC[816:321538] 3 - 得到网络请求数据

从打印的数据可以发现进行了三次网络请求，但是在实际开发过程中，我们并不想要请求三次，我们只想请求一次就够了。这个时候就可以用RACMulticastConnection这个类了，RACMulticastConnection其实是一个连接类，连接类的意思就是当一个信号被多次订阅，他可以帮我们避免多次调用创建信号中的block，基本用法如下：

RACSignal * signal = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
        NSLog(@"发送网络请求");
        
        [subscriber sendNext:@"得到网络请求数据"];
        
        return nil;
    }];
    
    RACMulticastConnection *connect = [signal publish];
    
    [connect.signal subscribeNext:^(id x) {
        NSLog(@"1 - %@",x);
    }];
    
    [connect.signal subscribeNext:^(id x) {
        NSLog(@"2 - %@",x);
    }];
    
    [connect.signal subscribeNext:^(id x) {
        NSLog(@"3 - %@",x);
    }];
    
    [connect connect];

其中需要注意的是一定要记得[connect connect]; 否则是不会进行连接的，也就没有任何效果。

<br />

二、内部实现

1、创建信号这个步骤就不用在多说了（保存了一个block，didSubscribe）

2、把信号转化成为一个连接类[signal publish]

• 在publish方法中首先创建了一个subject然后调用multicast创建了一个连接类，在创建连接类的时候把signal和subject保存了起来。

- (RACMulticastConnection *)publish {
    RACSubject *subject = [[RACSubject subject] setNameWithFormat:@"[%@] -publish", self.name];
    RACMulticastConnection *connection = [self multicast:subject];
    return connection;
}

- (RACMulticastConnection *)multicast:(RACSubject *)subject {
    [subject setNameWithFormat:@"[%@] -multicast: %@", self.name, subject.name];
    RACMulticastConnection *connection = [[RACMulticastConnection alloc] initWithSourceSignal:self subject:subject];
    return connection;
}

- (instancetype)initWithSourceSignal:(RACSignal *)source subject:(RACSubject *)subject {
    NSCParameterAssert(source != nil);
    NSCParameterAssert(subject != nil);

    self = [super init];

    _sourceSignal = source;
    _serialDisposable = [[RACSerialDisposable alloc] init];
    _signal = subject;
    
    return self;
}

3、在调用的时候就不是调用原来的signal了，而是调用connect连接类的信号，但是在publish这个方法中我们把subject保存了起来，所以还是在调用subject。
在init方法中赋值_signal = subject;

4、在最后的connect方法中，在用之前保存的signal订阅我们保存的subject,也就是说在这里才是真正的订阅了我们的信号，这个时候才会去调用我们最开始保存的didSubscribe这个block，而发送数据的其实是我们在publish中保存的subject，所以就完成了一次创建多次订阅了。

- (RACDisposable *)connect {
    BOOL shouldConnect = OSAtomicCompareAndSwap32Barrier(0, 1, &_hasConnected);

    if (shouldConnect) {
        self.serialDisposable.disposable = [self.sourceSignal subscribe:_signal];
    }

    return self.serialDisposable;
}

简易流程图