本篇来探索ReactiveCocoa的底层实现。主要从以下几个方面：

• RAC三种方式订阅是如何销毁的？
• RAC的调度者RACScheduler
  在上一个RAC基础篇
  里截图简单介绍了RAC信号响应的基本流程，这幅图依然放在这里，从这个信号响应流程开始探索：
  
  信号响应流程
  
  大致过程如下：
  
  
  在这个流程的基础上，我们继续往下探索。

一. 三种信号订阅形式，信号是如何销毁的

信号订阅的三种形式：Next,Error,Completed。不同形式的订阅方式，信号的销毁有什么不同呢？

1. 三种订阅形式的使用

首先，我们创建一个信号，使用属性mySubscriber保存订阅者，并在页面上添加三个按钮，分别发送不同形式的信号。代码如下：

 //创建信号
    RACSignal *signal = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
    //这里给了我们订阅者参数subscriber，意味着我们可以将订阅者用属性保存起来，在我们需要的地方进行信号发送。
        self.mySubscriber = subscriber;
        
        return [RACDisposable disposableWithBlock:^{
            NSLog(@"销毁!!!");
        }];
    }];

//点击按钮发送sendNext信号
- (void)clickmyBtn {
    [self.mySubscriber sendNext:@"Niki发送了一个信号"];
}
//点击按钮发送一个error信号
- (IBAction)clickErrorBtn:(id)sender {
    NSError *error = [NSError errorWithDomain:NSURLErrorDomain code:404 userInfo:@{@"msg":@"网络错误"}];
    [self.mySubscriber sendError:error];
}
//点击按钮发送一个完成信号
- (IBAction)clickCompleteBtn:(id)sender {
    [self.mySubscriber sendCompleted];
}

下面我们先订阅Next信号，点击发送sendNext信号的按钮，可以看出，不论按钮点击多少次，都会收到信号的打印，并且始终不会执行NSLog(@"销毁!!!");这句代码。也就是说，这个信号不会被销毁。

    //订阅Next信号
    [signal subscribeNext:^(id  _Nullable x) {
        NSLog(@"%@",x);
    }];

打印信息：

next打印信息

//订阅error信号
    [_signal subscribeError:^(NSError * _Nullable error) {
        NSLog(@"网络错误");
    }];

打印信息：

error打印信息

//订阅Completed
    [_signal subscribeCompleted:^{
        NSLog(@"完成");
    }];

Completed和error分别表示完成和报错，通常我们在封装网络请求时，请求完成会使用Completed，报错使用error，完成和报错都意味着信号已经没有用了，考虑到性能问题，信号不用一直处在等待响应的状态，所以发生一次就销毁了。
了解了代码的呈现形式，那么我们来看一看，RAC代码是怎么实现的。

2. 底层实现

这三个订阅方法是协议RACSubscriber的代理方法。

RACSubscriber代理

二. RAC的调度者RACScheduler

RAC的RACScheduler通过自主控制线程，来实现多线程的调度。下面我们来看它是如何实现多线程控制的。
继续来到刚才看过的RACDynamicSignal的- (RACDisposable *)subscribe:方法中，看schedule:方法。

• 首先不对线程进行操作，在主线程中创建以下信号：

- (void)viewDidLoad {
    [super viewDidLoad];
    //创建信号
    _signal = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        [subscriber sendNext:@"hi Niki"];
        return [RACDisposable disposableWithBlock:^{
            NSLog(@"销毁!!!");
        }];
    }];
    //订阅Next信号
    [_signal subscribeNext:^(id  _Nullable x) {
        NSLog(@"%@",x);
    }];
}

currentScheduler:先判断当前线程字典中有没有存储过RACScheduler对象，我们并没有对线程进行这样的操作，所以一定是nil，然后就会判断当前线程是否主线程，显然这里就会返回主线程的调度者。
返回之后，往回看- (RACDisposable *)schedule:中if判断不成立，直接执行block()。

• 第二种情况，在子线程中创建信号：

- (void)viewDidLoad {
    [super viewDidLoad];
    
    dispatch_async(dispatch_get_global_queue(0, 0), ^{
        //创建信号
        RACSignal *signal = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
            
            [subscriber sendNext:@"hi Niki"];
            
            return [RACDisposable disposableWithBlock:^{
                NSLog(@"销毁!!!");
            }];
        }];
        //订阅Next信号
        [signal subscribeNext:^(id  _Nullable x) {
            NSLog(@"%@",x);
        }];
    });
}

currentScheduler:先判断当前线程字典中有没有存储过RACScheduler对象，我们并没有对线程进行这样的操作，所以一定是nil，然后就会判断当前线程是否主线程，当前也非主线程，于是继续往下执行return nil;。
返回之后，往回看- (RACDisposable *)schedule:中if判断成立，执行[self.backgroundScheduler schedule:block]。
先看backgroundScheduler是什么？在这个类的初始化方法中已经初始化了backgroundScheduler属性。