上面抽丝剥茧的把最主要的信号机制给分离开了。但在RAC中各种操作也是必不可少的，一些复杂的操作符也是有一些基础操作拼接组合而来，有点搭积木的味道。
那我沿着之前的思路，写一些简单的操作符是如何实现的。
操作符之concat（拼接）
concat 使用示例
QHQSignal *demoOriginSignal = [QHQSignal createSignal:^(id subscriber) {
[subscriber sendNext:@"demoOriginSignal - send"];
[subscriber sendCompleted];
}];
QHQSignal *demoConcatSignal = [QHQSignal createSignal:^(id subscriber) {
[subscriber sendNext:@"demoConcatSignal - send"];
}];
[[demoOriginSignal concat:demoConcatSignal] subscribeNext:^(id x) {
NSLog(@"%@",x);
}];
输出内容
2015-12-25 10:02:45.966 PageText[88233:4685875] demoOriginSignal - send
2015-12-25 10:02:45.967 PageText[88233:4685875] demoConcatSignal - send
达到了拼接的效果
实现思路很简单，就是在第一个信号sendcompleted的时候，让subscirber订阅被拼接的信号。
-(QHQSignal *)concat:(QHQSignal *)concatSignal {
return [QHQSignal createSignal:^(id subscriber) {
[self subscribeNext:^(id next) {
[subscriber sendNext:next];
} error:^(NSError *error) {
[subscriber sendError:error];
} completed:^{
[concatSignal subscribe:subscriber];
}];
}];
}
可以看当self（源信号）发送next时，新信号也发送next，发送error，新信号也发送error。发送completed时，让订阅着订阅了被拼接的信号，这样就实现了拼接。
再实现一个复杂些的操作符zip，zip的作用是将2个信号进行压缩。每当2个信号都有新值来时，将两个新值以元组形势返回，demo中以数组返回。（元组可参见swift，这里rac以宏实现了元组的操作）。
QHQSignal *demoOriginSignal = [QHQSignal createSignal:^(id subscriber) {
[subscriber sendNext:@"demoOriginSignal - send- zip1"];
[subscriber sendNext:@"demoOriginSignal - send- zip2"];
}];
QHQSignal *demoConcatSignal = [QHQSignal createSignal:^(id subscriber) {
[subscriber sendNext:@"demoConcatSignal - send - zip1"];
[subscriber sendNext:@"demoConcatSignal - send - zip2"];
}];
[[demoOriginSignal zip:demoConcatSignal] subscribeNext:^(id x) {
NSLog(@"%@",x);
}];
输出结果
2015-12-25 11:10:44.546 PageText[89544:4713950] (
"demoOriginSignal - send- zip1",
"demoConcatSignal - send - zip1"
)
2015-12-25 11:10:44.547 PageText[89544:4713950] (
"demoOriginSignal - send- zip2",
"demoConcatSignal - send - zip2"
)
注释掉任意一个send后，都将减少一次输出，如果某个信号不发送内容，那么将不会有输出。
-(QHQSignal *)zip:(QHQSignal *)signal {
return [QHQSignal createSignal:^(id subscriber) {
NSMutableArray *selfArray = [NSMutableArray array];
NSMutableArray *zipArray = [NSMutableArray array];
void (^sendZip)(void) = ^{
if (selfArray.count == 0) return;
if (zipArray.count == 0) return;
NSArray *send = [NSArray arrayWithObjects:selfArray.firstObject, zipArray.firstObject,nil];;
[selfArray removeObjectAtIndex:0];
[zipArray removeObjectAtIndex:0];
[subscriber sendNext:send];
};
[self subscribeNext:^(id x) {
[selfArray addObject:x];
sendZip();
}];
[signal subscribeNext:^(id x) {
[zipArray addObject:x];
sendZip();
}];
}];
}
源码展示：压缩后的信号用两个数组表示压缩前信号的值。直到都有值时，才将信号打包输出。都是比较简单的实现。
剩下操作的可以自己根据源码分析用途了，明白了原理，用起来也更放心。