ReactiveCocoa-上手其实很简单(三)

今天来说一说RAC操作符的具体使用，使用操作符会让你的代码逻辑更清晰。如果对于之前的有遗忘，可以回顾下之前的文章上手其实很简单(一)、上手其实很简单(二)。接下来我们开始我们的学习。

RAC映射：

map:把源信号的值映射成一个新的值
**使用步骤: **
1.传入一个block,类型是返回对象，参数是value
2.value就是源信号的内容，直接拿到源信号的内容做处理
3.把处理好的内容，直接返回就好了，不用包装成信号，返回的值，就是映射的值。
例子：

-(void)map {
   RACSubject *subject = [RACSubject subject];  
   // 绑定信号  
   RACSignal *bindSignal = [subject map:^id(id value) {  
         
       // 返回的类型就是你需要映射的值  
       return [NSString stringWithFormat:@"添加下前缀:%@", value]; //拼接下传过来的值，映射返回出去
   }];  
   // 订阅绑定信号  
   [bindSignal subscribeNext:^(id x) {  
       NSLog(@"%@", x);  
   }];  
   // 发送信号  
   [subject sendNext:@"123"];  
 
}

FlatternMap:功能和map相同，主要用于信号中的信号
下边来坐下比较在处理信号中的信号的几种方法：

- (void)flattenMap2 {  
    // flattenMap 主要用于信号中的信号  
     //signalOfsignals用FlatternMap  
    // 创建信号  
    RACSubject *signalofSignals = [RACSubject subject];  
    RACSubject *signal = [RACSubject subject];  
      
    // 订阅信号  
    //方式1   一般不使用这个方法套的层数太多。
    //    [signalofSignals subscribeNext:^(id x) {  
    //  
    //        [x subscribeNext:^(id x) {  
    //            NSLog(@"%@", x);  
    //        }];  
    //    }];  
    // 方式2  这个在上篇文章(二)有介绍
    //    [signalofSignals.switchToLatest  ];  
    // 方式3  是flattenMap和订阅分开处理
    //   RACSignal *bignSignal = [signalofSignals flattenMap:^RACStream *(id value) {  
    //  
    //        //value:就是源信号发送内容  
    //        return value;  
    //    }];  
    //    [bignSignal subscribeNext:^(id x) {  
    //        NSLog(@"%@", x);  
    //    }];  
    // 方式4--------也是开发中常用的  (方法4和方法3相同，只不过4是把订阅跟flattenMap放到了一起来处理)
    [[signalofSignals flattenMap:^RACStream *(id value) {  
        return value;  
    }] subscribeNext:^(id x) {  
        NSLog(@"%@", x);  
    }];  
      
    // 发送信号  
    [signalofSignals sendNext:signal];  
    [signal sendNext:@"123"];  
}

map与flattenMap的区别：
1.FlatternMap中的Block返回信号。
2.Map中的Block返回对象。
3.开发中，如果信号发出的值不是信号，映射一般使用Map
4.开发中，如果信号发出的值是信号，映射一般使用FlatternMap。

RAC过滤

skip:skip传入n跳过前面n个值
使用场景: 在实际开发中比如后台返回的数据前面几个没用，我们想跳跃过去，便可以用skip

- (void)skip {  
    RACSubject *subject = [RACSubject subject];  
    [[subject skip:2] subscribeNext:^(id x) {  
        NSLog(@"%@", x);  //会打印第三个值
    }];  
    [subject sendNext:@1];  
    [subject sendNext:@2];  
    [subject sendNext:@3];  
}

distinctUntilChanged:-- 如果当前的值跟上一次的值一样，就不会被订阅到
使用场景:处理解决相同值没必要多次被订阅

- (void)distinctUntilChanged {  
    RACSubject *subject = [RACSubject subject];  
    [[subject distinctUntilChanged] subscribeNext:^(id x) {  
        NSLog(@"%@", x);  
    }];  
    // 发送信号  
    [subject sendNext:@1];  
    [subject sendNext:@2];  
    [subject sendNext:@2]; // 不会被订阅  
}

** take:**可以屏蔽一些值,去前面几个值---这里take为2 则只拿到前两个值

- (void)take {  
    RACSubject *subject = [RACSubject subject];  
    [[subject take:2] subscribeNext:^(id x) {  
        NSLog(@"%@", x);  
    }];  
    // 发送信号  
    [subject sendNext:@1];  
    [subject sendNext:@2];  
    [subject sendNext:@3];  
}

takeLast:和take的用法一样，不过他取的是最后的几个值，如下，则取的是最后两个值
注意点:takeLast 一定要调用sendCompleted，告诉他发送完成了，这样才能取到最后的几个值

- (void)takeLast {  
    RACSubject *subject = [RACSubject subject];  
    [[subject takeLast:2] subscribeNext:^(id x) {  
        NSLog(@"%@", x);  
    }];  
    // 发送信号  
    [subject sendNext:@1];  
    [subject sendNext:@2];  
    [subject sendNext:@3];  
    [subject sendCompleted];  //一定要sendCompleted   否则takeLast取不到最后你想要的值
}

** takeUntil:**---给takeUntil传的是哪个信号，那么当这个信号发送信号或sendCompleted，就不能再接受源信号的内容了。

- (void)takeUntil {  
    RACSubject *subject = [RACSubject subject];  
    RACSubject *subject2 = [RACSubject subject];  
    [[subject takeUntil:subject2] subscribeNext:^(id x) {  
        NSLog(@"%@", x);  
    }];  
    // 发送信号  
    [subject sendNext:@1];  
    [subject sendNext:@2];  
    [subject2 sendNext:@3];  // 1  调用后上边订阅不会收到下边发送的内容
//    [subject2 sendCompleted]; // 或2  同理一样不会收到下边发送的内容
    [subject sendNext:@4];  
}

ignore: 忽略掉一些值

- (void)ignore {  
    //ignore:忽略一些值  
    //ignoreValues:表示忽略所有的值  
    // 1.创建信号  
    RACSubject *subject = [RACSubject subject];  
    // 2.忽略一些值  
    RACSignal *ignoreSignal = [subject ignore:@2]; // ignoreValues:表示忽略所有的值  
    // 3.订阅信号  
    [ignoreSignal subscribeNext:^(id x) {  
        NSLog(@"%@", x);  
    }];  
    // 4.发送数据  
    [subject sendNext:@2];  
  
}

fliter:对于过滤而言，下边的才是经常使用的, 一般和文本框一起用，添加过滤条件

- (void)fliter {  
    // 只有当文本框的内容长度大于5，才获取文本框里的内容  
    [[self.textField.rac_textSignal filter:^BOOL(id value) {  
        // value 源信号的内容  
        return [value length] > 5;  
        // 返回值 就是过滤条件。只有满足这个条件才能获取到内容  
    }] subscribeNext:^(id x) {  
        NSLog(@"%@", x);  
    }];  
}

RAC合并操作

combineLatest:把多个信号聚合成你想要的信号
使用场景:比如-当多个输入框都有值的时候按钮才可点击，就是把输入框输入值的信号都聚合成按钮是否能点击的信号。

- (void)combineLatest {  
    RACSignal *combinSignal = [RACSignal combineLatest:@[self.accountField.rac_textSignal, self.pwdField.rac_textSignal] reduce:^id(NSString *account, NSString *pwd){ //reduce里的参数一定要和combineLatest数组里的一一对应。  
        // block: 只要源信号发送内容，就会调用，组合成一个新值。  
        NSLog(@"%@ %@", account, pwd);  
        return @(account.length && pwd.length);  
    }];  

    RAC(self.loginBtn, enabled) = combinSignal;     
}

zipWith:把两个信号压缩成一个信号，只有当两个信号同时发出信号内容时，并且把两个信号的内容合并成一个元祖，才会触发压缩流的next事件。
使用场:当一个界面多个请求的时候，要等所有请求完成才更新UI
注意:元组内元素的顺序跟发送的顺序无关，而是跟压缩的顺序有关[signalA zipWith:signalB]---先是A后是B

- (void)zipWith {  
    // 创建信号A  
    RACSubject *signalA = [RACSubject subject];  
    // 创建信号B  
    RACSubject *signalB = [RACSubject subject];  
    // 压缩成一个信号  
    // 等所有信号都发送内容的时候才会调用  
    RACSignal *zipSignal = [signalA zipWith:signalB];  
    [zipSignal subscribeNext:^(id x) {  
        NSLog(@"%@", x); //所有的值都被包装成了元组  
    }];  
    //发送信号 交互顺序，元组内元素的顺序不会变，跟发送的顺序无关，而是跟压缩的顺序有关[signalA zipWith:signalB]---先是A后是B  
    [signalA sendNext:@1];  
    [signalB sendNext:@2];  
  
}

** merge:**多个信号合并成一个信号，任何一个信号有新值就会调用 ,任何一个信号请求完成都会被订阅到

- (void)merge {  
    // 创建信号A  
    RACSubject *signalA = [RACSubject subject];  
    // 创建信号B  
    RACSubject *signalB = [RACSubject subject];  
    //组合信号  
    RACSignal *mergeSignal = [signalA merge:signalB];  
    // 订阅信号  
    [mergeSignal subscribeNext:^(id x) {  
        NSLog(@"%@", x);  
    }];  
    // 发送信号---交换位置则数据结果顺序也会交换  
    [signalB sendNext:@"下部分"];  
    [signalA sendNext:@"上部分"];  
}

** then **使用需求：有两部分数据：想让上部分先进行网络请求但是过滤掉数据，然后进行下部分的，拿到下部分数据

- (void)then {  
    // 创建信号A  
    RACSignal *signalA = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {  
        // 发送请求  
        NSLog(@"----发送上部分请求---afn");  
          
        [subscriber sendNext:@"上部分数据"];  
        [subscriber sendCompleted]; // 必须要调用sendCompleted方法！  
        return nil;  
    }];  
      
    // 创建信号B，  
    RACSignal *signalsB = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {  
        // 发送请求  
        NSLog(@"--发送下部分请求--afn");  
        [subscriber sendNext:@"下部分数据"];  
        [subscriber sendCompleted];  
        return nil;  
    }];  
    // 创建组合信号  
    // then;忽略掉第一个信号的所有值  
    RACSignal *thenSignal = [signalA then:^RACSignal *{  
        // 返回的信号就是要组合的信号  
        return signalsB;  
    }];  
      
    // 订阅信号  
    [thenSignal subscribeNext:^(id x) {  
        NSLog(@"%@", x);  
    }];  
  
}

concat----- 使用需求：有两部分数据：想让上部分先执行，完了之后再让下部分执行（都可获取值），类似于同步

- (void)concat {  
    // 组合  
      
    // 创建信号A  
    RACSignal *signalA = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {  
        // 发送请求  
        //        NSLog(@"----发送上部分请求---afn");  
          
        [subscriber sendNext:@"上部分数据"];  
        [subscriber sendCompleted]; // 必须要调用sendCompleted方法！  
        return nil;  
    }];  
      
    // 创建信号B，  
    RACSignal *signalsB = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {  
        // 发送请求  
        //        NSLog(@"--发送下部分请求--afn");  
        [subscriber sendNext:@"下部分数据"];  
        return nil;  
    }];  
 // concat:按顺序去链接  
    //**-注意-**：concat，第一个信号必须要调用sendCompleted  
    // 创建组合信号  
    RACSignal *concatSignal = [signalA concat:signalsB];  
    // 订阅组合信号  
    [concatSignal subscribeNext:^(id x) {  
        NSLog(@"%@",x);  
    }];  
  
}

RAC常用的宏
RAC宏：


- (void)test  
{  
    // RAC:把一个对象的某个属性绑定一个信号,只要发出信号,就会把信号的内容给对象的属性赋值  
    // 给label的text属性绑定了文本框改变的信号  
    RAC(self.label, text) = self.textField.rac_textSignal;  
}

KVO RACObserveL:快速的监听某个对象的某个属性改变返回的是一个信号,对象的某个属性改变的信号

- (void)test2 {  
    [RACObserve(self.view, center) subscribeNext:^(id x) {  
        NSLog(@"%@", x);  
    }];  
}  
- (void)testAndtest2 // textField输入的值赋值给label，监听label文字改变,  
{  
      
    RAC(self.label, text) = self.textField.rac_textSignal;  
    [RACObserve(self.label, text) subscribeNext:^(id x) {  
        NSLog(@"====label的文字变了");  
    }];  

 RAC(self.label, text) = RACObserve( self.textField, text) ；
      
}

** 循环引用问题 **

- (void)test3 {  
    @weakify(self)  
    RACSignal *signal = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {  
        @strongify(self)  
        NSLog(@"%@",self.view);  
        return nil;  
    }];  
    _signal = signal;  
}

** 元组:**

//快速包装一个元组 ,把包装的类型放在宏的参数里面,就会自动包装 
- (void)test4 {  
   RACTuple *tuple = RACTuplePack(@1,@2,@4);  
   // 宏的参数类型要和元祖中元素类型一致， 右边为要解析的元祖。  
   RACTupleUnpack_(NSNumber *num1, NSNumber *num2, NSNumber * num3) = tuple;// 4.元祖  
   // 快速包装一个元组  
   // 把包装的类型放在宏的参数里面,就会自动包装  
   NSLog(@"%@ %@ %@", num1, num2, num3);  
     
}

ReactiveCocoa-上手其实很简单(三)

ReactiveCocoa-上手其实很简单(三)

RAC映射：

RAC过滤

RAC合并操作

RAC基本的运用到此就告一段落，相信大家仔细看文章学习，也会使用了。祝大家生活愉快。

推荐阅读更多精彩内容