组合:
concat组合:
按一定顺序执行皇上与皇太子关系
concat底层实现:
1.当拼接信号被订阅，就会调用拼接信号的didSubscribe
2.didSubscribe中会先订阅第一个源信号（signalA）
3.会执行第一个源信号（signalA）的didSubscribe
4.第一个源信号（signalA）didSubscribe中发送值，就会调用第一个源信号（signalA）订阅者的nextBlock,通过拼接信号的订阅者把值发送出来.
5.第一个源信号（signalA）didSubscribe中发送完成，就会调用第一个源信号（signalA）订阅者的completedBlock,订阅第二个源信号（signalB）这时候才激活（signalB）。
6.订阅第二个源信号（signalB）,执行第二个源信号（signalB）的didSubscribe
7.第二个源信号（signalA）didSubscribe中发送值,就会通过拼接信号的订阅者把值发送出来.
//创建信号A
RACSignal*signalA =[RACSignal createSignal:^RACDisposable*(id subscriber) {
//发送请求
NSLog(@"上半部分的请求");
//发送信号
[subscriber sendNext:@"上半部分数据"];
//发送完毕
//加上后就可以上部分发送完毕后发送下半部分信号，这个必须要把信号A这个关闭，要不信号B就无法触发
[subscriber sendCompleted];
return nil;
}];
//创建信号B
RACSignal*signalB =[RACSignal createSignal:^RACDisposable*(id subscriber) {
//发送请求
NSLog(@"下半部分的请求");
//发送信号
[subscriber sendNext:@"下半部分数据"];
return nil;
}];
//创建组合信号
// contact：按顺序去连接（组合）
//注意：第一个信号必须调用sendCompleted
RACSignal*contactSignal = [signalA concat: signalB];
//订阅组合信号
[contactSignal subscribeNext:^(id x) {
//按顺序触发，当A信号触发完后，才可使走信号B中的方法，输出结果可以出结果
NSLog(@"%@",x);
}];
输出结果：
2016-08-15 10:02:23.060 RAC——oneday[2742:23026]上半部分的请求
2016-08-15 10:02:27.951 RAC——oneday[2742:23026]上半部分数据
2016-08-15 10:02:29.806 RAC——oneday[2742:23026]下半部分的请求
2016-08-15 10:02:32.961 RAC——oneday[2742:23026]下半部分数据
then:
用于连接两个信号，当第一个信号完成，才会连接then返回的信号
注意: 使用then之前的信号的值会被忽略掉.
底层实现：
1、先过滤掉之前的信号发出的值。
2.使用concat连接then返回的信号
//创建信号A
RACSignal*signalA = [RACSignalvcreateSignal:^RACDisposable*(id subscriber) {
//发送请求
NSLog(@"发送上部分的请求");
//发送信号
[subscriber sendNext:@"上部分的数据"];
//发送完毕
//加上后就可以发送上部分的完毕后发送下部分的信号
[subscriber sendCompleted];
return nil;
}];
//创建信号B
RACSignal*signalB = [RACSignal createSignal:^RACDisposable*(id subscriber) {
//发送请求
NSLog(@"发送下部分的请求");
//发送信号
[subscriber sendNext:@"下部分的数据"];
return nil;
}];
//创建组合信号
//then会忽略点第一个信号的所有值
RACSignal*signalThen = [signalA then:^RACSignal*{
//返回的信号就是需要组合的信号，这里回将signalA信号忽略点
return signalB;
}];
//订阅信号
[signalThen subscribeNext:^(idx) {
NSLog(@"%@",x);
}];
2016-08-15 10:06:27.643 RAC——oneday[4045:39265]发送上部分的请求
2016-08-15 10:06:27.645 RAC——oneday[4045:39265]发送下部分的请求
2016-08-15 10:06:31.261 RAC——oneday[4045:39265]下部分的数据
merge
把多个信号合并为一个信号，任何一个信号有新值的时候就会调用,没有顺序
//创建信号A
RACSubject*siganlA = [RACSubject subject];
//创建信号B
RACSubject*signalB = [RACSubject subject];
//组合信号
RACSubject*signalMerage = [siganlA merge:signalB];
//订阅信号
[signalMerage subscribeNext:^(id x) {
NSLog(@"%@",x);
}];
//发送数据，这里的发送消息不一定需要哪个信号发送完毕后才可以，没有限制
[signalB sendNext:@"下半部数据"];
[siganlA sendNext:@"上半部数据"];
2016-08-15 10:20:40.660 RAC——oneday[4894:49228]下半部数据
2016-08-15 10:20:40.660 RAC——oneday[4894:49228]上半部数据
zipWith:
等所有信号都发送内容的时候才会调用(夫妻关系)
把两个信号压缩成一个信号，只有当两个信号同时发出信号内容时，并且把两个信号的内容合并成一个元组，才会触发压缩流的next事件
底层实现:
1.定义压缩信号，内部就会自动订阅signalA，signalB
2.每当signalA或者signalB发出信号，就会判断signalA，signalB有没有发出个信号，有就会把最近发出的信号都包装成元组发出。
//创建信号A
RACSubject*signalA = [RACSubject subject];
//创建信号B
RACSubject*signalB = [RACSubject subject];
//压缩成一个信号
//当一个界面多个请求时，需要等所有的请求都完成才能更新UI
//打印顺序跟组合顺序，跟发送的顺序无关
//把两个信号合成一个信号
RACSignal*signalZipwith = [signalA zipWith:signalB];
//订阅信号
[signalZipwith subscribeNext:^(idx) {
NSLog(@"%@",x);
}];
//发送信号
[signalA sendNext:@"LUO"];
[signalB sendNext:@"CRAZY"];
2016-08-15 10:32:19.272 RAC——oneday[5618:57722] (
LUO,
CRAZY
)
combineLatest:
将多个信号合并起来，并且拿到各个信号的最新的值,必须每个合并的signal至少都有过一次sendNext，才会触发合并的信号。
底层实现：
1.当组合信号被订阅，内部会自动订阅signalA，signalB,必须两个信号都发出内容，才会被触发。
2.并且把两个信号组合成元组发出。
//创建信号A
RACSubject*signalA = [RACSubject subject];
//创建信号B
RACSubject*signalB = [RACSubject subject];
//把两个信号合成一个信号
RACSignal*signalCombineLatest = [signalA combineLatestWith:signalB];
//订阅组合信号
[signalCombineLatest subscribeNext:^(idx) {
NSLog(@"%@",x);
}];
[signalA sendNext:@"A"];
[signalB sendNext:@"B"];
2016-08-15 10:43:47.345 RAC——oneday[6427:66814] (
A,
B
)
reduce聚合:用于信号发出的内容是元组，把信号发出元组的值聚合成一个值
常见的用法（先组合在聚合）。combineLatest:(id)signals reduce:(id (^)())reduceBlock
reduce中的block简介:
reduceblcok中的参数，有多少信号组合，reduceblcok就有多少参数，每个参数就是之前信号发出的内容
reduceblcok的返回值：聚合信号之后的内容。
底层实现:
订阅聚合信号，每次有内容发出，就会执行reduceblcok，把信号内容转换成reduceblcok返回的值。
- (void)combineLatestWithReduce
{
/*登录界面:两个文本框(账户,密码) + 一个登录按钮*/
//组合多个信号
//reduce:聚合
//reduceBlock的参数与组合的信号一一对应,可以在reduce:后拿到信号的值
RACSignal *combineSignal = [RACSignal combineLatest:@[_accountName.rac_textSignal, _passWord.rac_textSignal] reduce:^id(NSString *account, NSString *pwd){
//block:只要源信号发送内容就会调用,组合成新的一个值
//聚合的值就是组合信号的内容
return @(account.length && pwd.length);
}];
//订阅信号
// [combineSignal subscribeNext:^(id x) {
// self.loginBtn.enabled = [x boolValue];
//
// }];
//等同于
RAC(self.loginBtn, enabled) = combineSignal;
}