文章系列
《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~10
信号订阅真正的生命周期关系持有图
关系持有图
附截图代码:
- (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
