文章系列
《ReactiveCocoa 概述》
《RACSignal》
《RACDisposable》
《RACSubject、RACReplaySubject(内附冷信号和热信号的区别)》
《集合RACTuple、RACSequence》
《RAC 中的通知、代理、KVO, 基本事件、方法的监听》
《rac_liftSelector》
《RACMulticastConnection》
《RACCommand》
《RAC - 核心方法bind》
《RAC - 定时器》
《RACScheduler》
《RAC - 点击获取验证码 demo》
《RAC - 映射(Map & flattenMap)》
《RAC信号操作解释合集》
《RAC - 信号的生命周期》
RACSignal: 信号类, 本身不具备发送信号的能力, 当被订阅后, 用于传递改变的数据, 可传递以下三种状态：
- sendNext(id)：可理解为传递正确数据，告诉订阅者进行下一步处理
- sendError：传递的数据错误，告诉订阅者错误处理
- sendCompleted：告诉订阅者已完成
-
流程图:signal.png
代码分析 (
注释很详细!!!)
- (void)signalTest {
/* 1. 创建信号 signal
- 通过 createSignal: 方法创建,其参数为一个返回值位RACDisposable 类型的block (didSubcribe)
*/
RACSignal *signal = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber> _Nonnull subscriber) {
// 2. 通过block 传入的订阅者subscriber 来发送信息
[subscriber sendNext:@10];
// sendError、sendCompleted 二者只能发送其一, 就代表结束了.
[subscriber sendError:[NSError errorWithDomain:@"错误" code:1001 userInfo:nil]];
[subscriber sendCompleted];
// 这里需要返回一个RACDisposable 类型的对象, 用于提前结束订阅等操作, 一般无特殊需求, 返回nil 即可.
return nil;
}];
/* 3. 订阅者 (subscriber)
- subscribeNext + error + completed 组合起来就是订阅者
- 一旦订阅者订阅了信号消息, 就会执行上面的didSubcribe 的block.
*/
[signal subscribeNext:^(id _Nullable x) {
NSLog(@"%@", x);
} error:^(NSError * _Nullable error) {
NSLog(@"ERROR=%@", error);
} completed:^{
NSLog(@"完成");
}];
}
- ↓分析 [RACSignal createSignal:]内部实现↓:
// 第1次点击方法跳转内部实现:
+ (RACSignal *)createSignal:(RACDisposable * (^)(id<RACSubscriber> subscriber))didSubscribe {
// 内部创建RACDynamicSignal 信号, 并将外部block 继续传递
return [RACDynamicSignal createSignal:didSubscribe];
}
// 第2次点击方法跳转内部实现:
+ (RACSignal *)createSignal:(RACDisposable * (^)(id<RACSubscriber> subscriber))didSubscribe {
// 1. 创建 RACDynamicSignal对象
// 2. 保存以参数形式传递进来的 block
// 3. 返回 RACDynamicSignal 对象
RACDynamicSignal *signal = [[self alloc] init];
signal->_didSubscribe = [didSubscribe copy];
return [signal setNameWithFormat:@"+createSignal:"];
}
- ↓分析 订阅者 订阅过程的实现(
源码逻辑分析, 帮助理解)↓:
// 开始订阅
[signal subscribeNext:^(id _Nullable x) {
// 订阅信号之后得到带有一个参数为 x的 block
NSLog(@"%@", x);
}];
// 点击 [signal subscribeNext:]内部实现
- (RACDisposable *)subscribeNext:(void (^)(id x))nextBlock {
NSCParameterAssert(nextBlock != NULL);
// 创建订阅者 o
RACSubscriber *o = [RACSubscriber subscriberWithNext:nextBlock error:NULL completed:NULL];
return [self subscribe:o];
}
// 点击[RACSubscriber subscriberWithNext:] 内部实现
+ (instancetype)subscriberWithNext:(void (^)(id x))next error:(void (^)(NSError *error))error completed:(void (^)(void))completed {
// 1. 创建订阅者对象
RACSubscriber *subscriber = [[self alloc] init];
// 2. 保存Next block 、error block 、completed block
subscriber->_next = [next copy];
subscriber->_error = [error copy];
subscriber->_completed = [completed copy];
// 3. 返回订阅者
return subscriber;
}
// 点击[self subscribe:o] 内部实现
- (RACDisposable *)subscribe:(id<RACSubscriber>)subscriber {
NSCParameterAssert(subscriber != nil);
RACCompoundDisposable *disposable = [RACCompoundDisposable compoundDisposable];
subscriber = [[RACPassthroughSubscriber alloc] initWithSubscriber:subscriber signal:self disposable:disposable];
// 4. 这里判断didSubcribe是 否为空
// didSubcribe 对象就是signal 的block 对象
if (self.didSubscribe != NULL) {
RACDisposable *schedulingDisposable = [RACScheduler.subscriptionScheduler schedule:^{
// 这里就在调用didSubscribe 方法，并且把刚传入的 subscriber 调用出去
// 5. 也就是说, 要执行 signal对象创建方法的 block
RACDisposable *innerDisposable = self.didSubscribe(subscriber);
[disposable addDisposable:innerDisposable];
}];
[disposable addDisposable:schedulingDisposable];
}
return disposable;
}
- 通过注释5 可以知道, 接下来就会调用[subscriber sendNext:@10] 等操作, 这也就是信号的发送.
↓sendNext 源码↓
- (void)sendNext:(id)value {
@synchronized (self) {
void (^nextBlock)(id) = [self.next copy];
// 6. nextblock 不为空就把传进来传value 原封不动的调用出去, 而这个nextblock就是我们在订阅信号的时候创建的那个subscriber 所保存的nextblock
if (nextBlock == nil) return;
nextBlock(value);
}
}
- 通过注释6 可以知道, 信号通过send 操作, 回调出来, 进行打印.
[signal subscribeNext:^(id _Nullable x) {
// 打印 x
NSLog(@"%@", x);
}];
总结:
所以RACSignal的处理流程就是
创建信号的block会在订阅信号的时候调用
订阅信号的block会在订阅者发布信息的时候调用
.End
