- 1.1,依赖concat,比如A请求依赖B请求,只有B请求完成之后才能执行A请求或操作
//1.1,依赖concat,比如A请求依赖B请求,只有B请求完成之后才能执行A请求或操作
RACSignal *signalA = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
[subscriber sendNext:@"signalA"];
return nil;
}];
RACSignal *signalB = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
[subscriber sendNext:@"signalB"];
//应为A依赖B,所以只需要在B里面声明完成即可
[subscriber sendCompleted];
return nil;
}];
//注意点:如果一个操作后面还被其他操作依赖,比如signalB,需要在其内部发送完数据后声明发送完成,[subscriber sendCompleted];
RACSignal *contatSignal = [signalB concat:signalA];
[contatSignal subscribeNext:^(id x) {
NSLog(@"%@",x);
}];
- 1.2,依赖then,比如A请求依赖B请求,只有B请求完成之后才能执行A请求或操作,但是需要注意:这个方法最后只能拿到B的值,如果A不需要传值,只需要先进行某些操作的时候可以用then
//1.2,依赖then,比如A请求依赖B请求,只有B请求完成之后才能执行A请求或操作,但是需要注意:这个方法最后只能拿到B的值,如果A不需要传值,只需要先进行某些操作的时候可以用then
RACSignal *signalA = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
[subscriber sendNext:@"signalA"];
return nil;
}];
RACSignal *signalB = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
[subscriber sendNext:@"signalB"];
//应为A依赖B,所以只需要在B里面声明完成即可
[subscriber sendCompleted];
return nil;
}];
//注意点:如果一个操作后面还被其他操作依赖,比如signalB,需要在其内部发送完数据后声明发送完成,[subscriber sendCompleted];
RACSignal *thenSignal = [signalB then:^RACSignal *{
return signalA;
}];
[thenSignal subscribeNext:^(id x) {
NSLog(@"%@",x);
}];
- 1.3,合并merge,多个信号合成一个信号,任何一个发出信号都会调用
//1.3,合并merge,多个信号合成一个信号,任何一个发出信号都会调用
RACSignal *signalA = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
[subscriber sendNext:@"signalA"];
return nil;
}];
RACSignal *signalB = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
[subscriber sendNext:@"signalB"];
//应为A依赖B,所以只需要在B里面声明完成即可
[subscriber sendCompleted];
return nil;
}];
RACSignal *mergeSignal = [signalA merge:signalB];
[mergeSignal subscribeNext:^(id x) {
NSLog(@"%@",x);
}];
- 1.4,信号压缩,把多个信号压缩成一个信号,只有被压缩的信号同时发出消息时才能调用
//1.4,信号压缩,这个方法其实和rac_liftSelector本质时一样的,把多个信号压缩成一个信号,只有被压缩的信号全部发出消息时才能调用
RACSignal *signalA = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
[subscriber sendNext:@"signalA"];
return nil;
}];
RACSignal *signalB = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
[subscriber sendNext:@"signalB"];
//应为A依赖B,所以只需要在B里面声明完成即可
[subscriber sendCompleted];
return nil;
}];
//这里是由顺序的哦
RACSignal *zipSignal = [signalB zipWith:signalA];
[zipSignal subscribeNext:^(id x) {
//x是接受到的所有数据包装成的元组
NSLog(@"%@",x);
}];
- 1.5,先组合后聚合(最常用),可以两句代码搞定登录逻辑
//注意:reduce这个block是有参数的,参数需要自己添上面,也即是你监听信号的个数
//1.5,先组合后聚合(最常用),可以两句代码搞定登录逻辑
//注意:reduce这个block是有参数的,参数需要自己添上面,也即是你监听信号的个数
RACSignal *combineSignal = [RACSignal combineLatest:@[_account.rac_textSignal, _pwd.rac_textSignal] reduce:^id(NSString *account, NSString *pwd){
NSLog(@"%@----%@", account, pwd);
NSLog(@"%@", @(account.length && pwd.length));
return @(account.length && pwd.length);
}];
/*
[combineSignal subscribeNext:^(id x) {
_login.enabled = [x boolValue];
}];
*/
RAC(_login,enabled) = combineSignal;