RAC源码分析
简要而言：RAC事实上就是对block进行copy和封装，在需要的时候进行调用的时候再拿出来调用。在signal的创建阶段保存创建block，在subscribe阶段调用创建的block来创建一个subscriber并在subscriber中保存需要执行的block，最后在send阶段执行执行的block。综上，RACSignal就是保存一个构造函数，再执行构造函数生成observer保存执行函数，在sendnext执行保存的执行函数，一共两步保存两步执行：保存、执行+保存、执行 分别对应create，subscribe和send阶段。
RACSignal
self.signal = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
[blockButton addTarget:subscriber action:@selector(sendNext:) forControlEvents:UIControlEventTouchUpInside];
return [RACDisposable disposableWithBlock:^{
[blockButton removeTarget:subscriber action:@selector(sendNext:) forControlEvents:UIControlEventTouchUpInside];
}];
}];
- 以上这个代码块还尚未被调用只是被保存了下来留到subscribe的时候使用它创建一个subscriber，进入createSignal的实现看到：
+ (RACSignal *)createSignal:(RACDisposable * (^)(id<RACSubscriber> subscriber))didSubscribe {
return [RACDynamicSignal createSignal:didSubscribe];
}
- 创建的是一个DynamicSignal，看这名字好像是Signal的一个子类？点开一看针地秀！为什么父类的create方法怎么调用子类的创建方法，RACSignal在.m文件中偷偷包含了子类DynamicSignal的.h文件。RACSignal把传入的参数原封不动地传给了子类的构建函数，意思就是：你要创建一个可以工作的信号？好的我自己比较抽象，只负责指导儿子们工作，我派我最得意的儿子动态信号给你干活。点开子类DynamicSignal的创建方法：
+ (RACSignal *)createSignal:(RACDisposable * (^)(id<RACSubscriber> subscriber))didSubscribe {
RACDynamicSignal *signal = [[self alloc] init];
signal->_didSubscribe = [didSubscribe copy];
return [signal setNameWithFormat:@"+createSignal:"];
}
- 真正干活的儿子复制了自己的一个本地，然后保存了一个didSubscribe的备份，质疑道signal是copy类型的代码块指针，被copy和strong指针指向的代码块都会在堆区复制一个副本来，这里就完成了第一步的保存，保存的是subscribe代码块，也就是构建subscriber的代码块。
[self.signal subscribeNext:^(id x) {
NSLog(@"仙人板板");
}];
- (RACDisposable *)subscribeNext:(void (^)(id x))nextBlock {
NSCParameterAssert(nextBlock != NULL);
RACSubscriber *o = [RACSubscriber subscriberWithNext:nextBlock error:NULL completed:NULL];
return [self subscribe:o];
}
- 哦？创建了一个RACSubscriber，初始化的时候把这个next当参数传进去了，还传了两个NULL值。什么时候这个NULL值不是NULL呢？
- (RACDisposable *)subscribeError:(void (^)(NSError *error))errorBlock {
NSCParameterAssert(errorBlock != NULL);
RACSubscriber *o = [RACSubscriber subscriberWithNext:NULL error:errorBlock completed:NULL];
return [self subscribe:o];
}
- (RACDisposable *)subscribeCompleted:(void (^)(void))completedBlock {
NSCParameterAssert(completedBlock != NULL);
RACSubscriber *o = [RACSubscriber subscriberWithNext:NULL error:NULL completed:completedBlock];
return [self subscribe:o];
}
- 往下看，哦，subscribeNext就把block当next传进去了，subscribeError，就把block当error传进去了，传subscribeCompleted就把block当completed参数传进去了；对啊！都传也行！
- (RACDisposable *)subscribeNext:(void (^)(id x))nextBlock error:(void (^)(NSError *error))errorBlock completed:(void (^)(void))completedBlock {
NSCParameterAssert(nextBlock != NULL);
NSCParameterAssert(errorBlock != NULL);
NSCParameterAssert(completedBlock != NULL);
RACSubscriber *o = [RACSubscriber subscriberWithNext:nextBlock error:errorBlock completed:completedBlock];
return [self subscribe:o];
}
- subscribeNext，subscribecompleted，subscribeError，分三个函数执行和一起执行的区别就是创建了三个subscriber分别保存一个block和一个subscriber保存三个block的区别。哦，结尾还执行了[self subscribe:0];点开:诶，怎么还需要选择类？注意到执行的是[self subscribe:o];刚才创建的是dynamicSignal，所以选的是DynamicSignal；如果你点开的是RACSignal，会出现这样一句代码：
NSCAssert(NO, @"This method must be overridden by subclasses");
- 父类的subscribe函数必须要子类重写，所以刚才选择的那些项都是Signal的子类，发现其中还有RACSubject，打开DynamicSignal的subscribe函数:
- (RACDisposable *)subscribe:(id<RACSubscriber>)subscriber {
NSCParameterAssert(subscriber != nil);
RACCompoundDisposable *disposable = [RACCompoundDisposable compoundDisposable];
subscriber = [[RACPassthroughSubscriber alloc] initWithSubscriber:subscriber signal:self disposable:disposable];
if (self.didSubscribe != NULL) {
RACDisposable *schedulingDisposable = [RACScheduler.subscriptionScheduler schedule:^{
RACDisposable *innerDisposable = self.didSubscribe(subscriber);
[disposable addDisposable:innerDisposable];
}];
[disposable addDisposable:schedulingDisposable];
}
return disposable;
}
- 重点在这里：RACDisposable *innerDisposable = self.didSubscribe(subscriber);执行了一次didSubscribe代码块，这个didSubscribe代码块是怎么拿到的？见上文dynamicSignal的create函数第二句：signal->_didSubscribe = [didSubscribe copy];就是在创建的时候复制了一份block到堆中，（因为在函数中声明的block通常为栈block，函数结束就随生命周期结束释放了，而通常create，subscribe和send都是在不同的函数中调用的，block必须保存为堆block）。所以在这个didSubscribe代码块中需要做就是规定好observer的触发条件，网上一大堆例子直接在didSubscribe块中调用了[observer sendNext]和[observer sendCompleted]组合;这个是什么触发条件？只在调用didSubscribe执行的时候才会发射信号。。。原谅我没有看懂这种操作，这种信号之后是怎么触发的呢？
- 以上是第二步的“执行+保存”。执行的是didsubscribe，保存的是next，completed，error三种block。
- 最后一步send就简单了，假装在didSubcribe代码块中写一句[subcriber sendNext:nil];(因为signal对外没有sendNext方法暴露出来，只能调用subcriber的sendNext方法，不过没关系，只是点进去看看)代码如下:
- (void)sendNext:(id)value {
@synchronized (self) {
void (^nextBlock)(id) = [self.next copy];
if (nextBlock == nil) return;
nextBlock(value);
}
}
- 懂了，直接运行了之前保存好的nextBlock；那我sendCompleted呢？直接completedBlock()？那还用薛呀？当岩了！error呢？。。。
- (void)sendCompleted {
@synchronized (self) {
void (^completedBlock)(void) = [self.completed copy];
[self.disposable dispose];
if (completedBlock == nil) return;
completedBlock();
}
}
- 给出RACSignal使用的正确姿势:textField_signal；引入ReactiveCocoa头文件，随便创建一个textfield;textField.rac_textSignal,点进去rac_textSignal,代码如下：
- (RACSignal *)rac_textSignal {
@weakify(self);
return [[[[[RACSignal
defer:^{
@strongify(self);
return [RACSignal return:self];
}]
concat:[self rac_signalForControlEvents:UIControlEventAllEditingEvents]]
map:^(UITextField *x) {
return x.text;
}]
takeUntil:self.rac_willDeallocSignal]
setNameWithFormat:@"%@ -rac_textSignal", self.rac_description];
}
- 类别为textField添加textSignal属性。重点在这:[self rac_signalForControlEvents:UIControlEventAllEditingEvents]]点进去看到：
- (RACSignal *)rac_signalForControlEvents:(UIControlEvents)controlEvents {
@weakify(self);
return [[RACSignal
createSignal:^(id<RACSubscriber> subscriber) {
@strongify(self);
[self addTarget:subscriber action:@selector(sendNext:) forControlEvents:controlEvents];
[self.rac_deallocDisposable addDisposable:[RACDisposable disposableWithBlock:^{
[subscriber sendCompleted];
}]];
return [RACDisposable disposableWithBlock:^{
@strongify(self);
[self removeTarget:subscriber action:@selector(sendNext:) forControlEvents:controlEvents];
}];
}]
setNameWithFormat:@"%@ -rac_signalForControlEvents: %lx", self.rac_description, (unsigned long)controlEvents];
}
- 重点在这:[self addTarget:subscriber action:@selector(sendNext:) forControlEvents:controlEvents];哦，在这里每次textField发生event都会到subscriber中调用nextBlock。使用一个信号就实现了对events的监听。若仿照其实现对一个按钮的点击事件的监听：
self.signal = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
[blockButton addTarget:subscriber action:@selector(sendNext:) forControlEvents:UIControlEventTouchUpInside];
return [RACDisposable disposableWithBlock:^{
[blockButton removeTarget:subscriber action:@selector(sendNext:) forControlEvents:UIControlEventTouchUpInside];
}];
}];
- 在didSubscribe块中直接[subScriber sendNext];的写法有什么使用场景。。我一直没搞明白；上面这个写法值得注意的是如果在disposableblock中没有removeTarget是没法正常绑定的，这个问题我问了很多讨论群里的大神，都没有给出比较好的答案，暂时存疑。disposible块中通常做一些类似dealloc函数里面进行的操作。
- Subject继承自RACSignal，可以直接[subject sendNext];，这个sendNext是把存在subject数组中的所有subscriber遍历一遍都执行nextBlock:
- (void)sendNext:(id)value {
[self enumerateSubscribersUsingBlock:^(id<RACSubscriber> subscriber) {
[subscriber sendNext:value];
}];
}
结束
