文章系列
《ReactiveCocoa 概述》
《RACSignal》
《RACDisposable》
《RACSubject、RACReplaySubject(内附冷信号和热信号的区别)》
《集合RACTuple、RACSequence》
《RAC 中的通知、代理、KVO, 基本事件、方法的监听》
《rac_liftSelector》
《RACMulticastConnection》
《RACCommand》
《RAC - 核心方法bind》
《RAC - 定时器》
《RACScheduler》
《RAC - 点击获取验证码 demo》
《RAC - 映射(Map & flattenMap)》
《RAC信号操作解释合集》
《RAC - 信号的生命周期》

本文主要分三部分

冷信号的实例状态 (内部调用关系)
热信号的实例状态 (内部调用关系)
信号订阅真正的生命周期

1. 冷信号的实例状态

图片解析: 注意序号1~7

冷信号的实例状态

附截图代码:

#pragma mark - 冷信号的实例状态: 所有对象都加在autoreleasepool 中!!!

// 冷信号的生命周期

- (void)lifeCycle {
    
    // 创建RACSignal 对象, 内部存在一个didSubscribe 对象
    RACSignal *signal = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber)
                         
    // 在信号订阅(subscribeNext:)的过程中, 也就是传入x、error 等参数时, 会生成一个订阅者RACSubscriber 对象, 该对象包含三个对象属性(nextBlock对象、errorBlobk对象、completedBlock对象)
    {
        // didSubscribe 对象 中获得subscriber 对象, 依次执行里面的代码, 例如: 执行sendNext: 时, 就会去subscriber对象里找nextBlock 对象, 并执行nextblock, 当内部一执行, 就会回调给外界
        [subscriber sendNext:@(10)];
        [subscriber sendNext:@(20)];
        
        // 当内部的subscriber 对象 执行完[subscriber sendCompleted]; 后, 会将subscriber 对象中的三个闭包对象(nextBlock对象、errorBlobk对象、completedBlock对象), 全部置为nil, 来解决对象的释放问题
        [subscriber sendCompleted];
        
        // 内部执行完return nil; 代表着所有的函数都已执行结束了, 所有对象等待着autoreleasepool 自动释放
        return nil;
    }];
    
    // 外面的订阅者生成之后, 以参数的形式传递给创建RACSignal 对象中的didSubscribe 对象, 也就是:
    [signal subscribeNext:^(id  _Nullable x)
    {
        NSLog(@"next: %@", x);
    }
    error:^(NSError * _Nullable error)
    {
        NSLog(@"error: %@", error);
    }
    completed:^
    {
        NSLog(@"completed");
    }];
}

2. 热信号的实例状态

图片解析: 注意序号1~5

热信号的实例状态

附截图代码:

// 热信号的生命周期: 同样多有对象都被加在 autoreleasepool 中

- (void)lifeCycle {
    
    // 创建RACSubject 对象, 内部存在一个Subscribers 对象, 是一个可变数组, 里面存储众多的订阅者
    RACSubject *subject = [RACSubject subject];
    
    // 在信号订阅(subscribeNext:)的过程中,会生成一个订阅者RACSubscriber 对象, 该对象包含三个对象属性(nextBlock对象、errorBlobk对象、completedBlock对象)
    // 外面的订阅者生成之后, 会通过add 操作将订阅者RACSubscriber 对象添加到RACSubject 对象的Subscribers 数组中
    [subject subscribeNext:^(id  _Nullable x)
    {
        NSLog(@"%@", x);
    }
    error:^(NSError * _Nullable error)
    {
        NSLog(@"%@", error);
    }
    completed:^
    {
        NSLog(@"completed");
    }];
    
    // 当执行[subject sendNext:@(10)]; 时,RACSubject 对象会遍历Subscribers, 然后再去每一个订阅者中寻找对应的block并执行, 在这里也就是nextBlock
    [subject sendNext:@(10)];
    
    // 当执行[subject sendCompleted]; 后,会将subscriber 对象中的三个block 对象全部置为nil, 来解决对象的释放问题, 也就等待着autoreleasepool 自动释放
    [subject sendCompleted];
}

3. 信号订阅真正的生命周期

1. 冷热信号的实例状态只是在通俗易懂的情况下, 抽象理解信号的生命周期
2. 要将上面的全部忘掉,然后往下看

3. 图片解析: 注意序号1~10

   
   信号订阅真正的生命周期

4. 关系持有图

   
   关系持有图

附截图代码:

- (void)lifeCycle {

    // 1.创建RACSignal 对象, 内部保存一个didSubscribe 对象.
    RACSignal *signal = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        
        // 3. [subscriber sendNext:@1]; 将1 这个值传递个系统订阅者subscriber , 系统订阅者subscriber 将1 再传递给用户订阅者, 用户订阅者执行nextBlock().
        [subscriber sendNext:@1];
        
        // 4. main sheduler(GCD) 的task 持有sheduler 和 send event async block这个do something 的代码块
        [RACScheduler.mainThreadScheduler afterDelay:2 schedule:^{
            
            [subscriber sendNext:@2];
            [subscriber sendCompleted];
        }];

        // 5. return 的disposable 是一个内部的disposable 对象, 当代对象生成之后, 会通过系统订阅者subscriber 操作成被系统disposalbe 对象所持有.
        return [RACDisposable disposableWithBlock:^{
            
            NSLog(@"内部的 Disposable dispose了");
        }];
    }];
    
    // 2.
    // 订阅信号过程中, 一方面在'外部'生成'用户订阅者' User Subscriver(也包含3个block 对象).
    /* 订阅信号过程中, 另一方面,
        1. 生成'真正'的订阅者 => '系统订阅者' subscriber.
        2. 生成系统的disposalbe 对象.
        3. 系统订阅者subscriber 对系统disposalbe 是持有关系, 也就是强引用, 以便随时用来销毁或者结束任务.
        4. 当内、外部订阅者都生成的情况下, 系统订阅者对用户订阅者进行持有(强引用, 用户订阅者将三个block对象传递给系统订阅者).
        5. 正常情况下, 订阅者与RACSignal 对象本身没有任何关系, 但是本质上是存在weakSelf/strongSelf 的弱引用关系, 以便在RACSignal 未销毁时, 订阅者方便调试打印.
        6. 系统订阅者以参数的形式传递个didSubscribe 对象.
        7. 得到的disposalbe 对象是系统的disposalbe, 因为不管didSubscribe 对象内部返回正常的didSubscribe 对象或者是nil, 外界都会得到一个disposalbe 对象.
     */
    RACDisposable *disposable = [signal subscribeNext:^(id  _Nullable x) {
        // 3. NSLog(@"%@", x); 打印 1
        NSLog(@"%@", x);
    } completed:^ {
          
        NSLog(@"completed");
    }];
    
    // 6. main sheduler(GCD) 的task 持有系统的disposable对象, [disposable dispose]; 时, 因为系统的订阅者subscriber 一直持有者系统的disposable 对象, 所以当系统的disposable 对象dispose 时, 系统的订阅者subscriber 将通知用户订阅者将内部的三个block 对象都置为nil. 且系统disposable 对象会对所有引用的内部disposable 对象发送dispose, 这时就会打印'内部的 Disposable dispose了', 同时, 系统的disposable 对象将不再持有内部的disposable 对象.
    [RACScheduler.mainThreadScheduler afterDelay:1 schedule:^ {
       
        [disposable dispose];
    }];
}

.End