RAC之信号组合

作者: 张不二01 | 来源:发表于2017-01-03 11:25 被阅读0次

RAC之信号组合
RAC信号组合
6.RAC之组合信号
小驴拉磨之—ReactiveCocao（RAC）组合信号
RAC 中的信号组合
RAC之组合
iOS开发「RAC」RAC信号组合的妙用
01-ReactiveObjC使用记录
iOS ReactiveCocoa学习笔记(3)：信号传递与数据
RAC - ObjC

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;