ReactiveCocoa源码拆分解析(二)
内容导读
互联网集市收集整理的这篇技术教程文章主要介绍了ReactiveCocoa源码拆分解析(二)，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含2720字，纯文字阅读大概需要4分钟。
内容图文
上面抽丝剥茧的把最主要的信号机制给分离开了。但在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();
}];
}];
}
源码展示：压缩后的信号用两个数组表示压缩前信号的值。直到都有值时，才将信号打包输出。都是比较简单的实现。
剩下操作的可以自己根据源码分析用途了，明白了原理，用起来也更放心。
原文：http://www.cnblogs.com/qianhongqiang/p/5075334.html
内容总结
以上是互联网集市为您收集整理的ReactiveCocoa源码拆分解析(二)全部内容，希望文章能够帮你解决ReactiveCocoa源码拆分解析(二)所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。
内容备注
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。
内容手机端
扫描二维码推送至手机访问。