2018 January 05 RAC

RAC系列3之常见的操作方法

注: RAC这一些列文章主要参考了小码哥袁峥和雷纯峰这两位大佬的博客

ReactiveCocoa常见操作方法

操作方法:
1. 所谓的操作方法:就是讲讲RACStream.h文件中声明的一些常用方法
2. 因为所有信号(RACSignal)都最终继承自RACStream这个类,因此这个类中的方法,所有信号都有.
ReactiveCocoa操作思想
1. 运用的是Hook（钩子）思想，Hook是一种用于改变API(应用程序编程接口：方法)执行结果的技术.
2. Hook用处：截获API调用的技术。
3. Hook原理：在每次调用一个API返回结果之前，先执行你自己的方法，改变结果的输出。即:在返回结果之前,拦截你的内容,然后返回新的结果
4. 如图:
如何体现的hook思想呢?就在下面这些操作方法中体现

ReactiveCocoa核心操作方法之绑定(`bind` )

ReactiveCocoa操作的核心方法是bind（绑定）,而且RAC中核心开发方式，也是绑定，之前的开发方式是赋值，而用RAC开发，应该把重心放在绑定，也就是可以在创建一个对象的时候，就绑定好以后想要做的事情，而不是等赋值之后在去做事情。
列如：把数据展示到控件上，之前都是重写控件的setModel方法，用RAC就可以在一开始创建控件的时候，就绑定好数据。
bind(绑定),结合RAC中的信号进行绑定,只要信号已发送数据,就能监听到,从而把发送的数据改成字节想要的数据
在开发中很少使用bind方法，bind属于RAC中的底层方法，RAC已经封装了很多好用的其他方法，底层都是调用bind，用法比bind简单.
bind方法分析:
- (__kindof RACStream *)bind:(RACStreamBindBlock (^)(void))block;
1. 参数:block(参数block返回值也是一个block(RACStreamBindBlock))
  1. 参数: 无
  2. 返回值:RACStreamBindBlock
2. 返回值:RACSignal(处理后的信号)
3. RACStreamBindBlock:
  1. 定义:
    1. typedef RACSequence * _Nullable (^RACSequenceBindBlock)(ValueType _Nullable value, BOOL *stop);
  2. 参数:value,stop
    1. value:表示接收到信号的原始值，还没做处理
    2. *stop:用来控制绑定Block，如果*stop = yes,那么就会结束绑定。
  3. 返回值:RACSignal(信号)，做好处理，在通过这个信号返回出去，一般使用RACReturnSignal,需要手动导入头文件RACReturnSignal.h。
注意:
1. 不同订阅者，保存不同的nextBlock，看源码的时候，一定要看清楚订阅者是哪个。
2. 这里需要手动导入#import <ReactiveCocoa/RACReturnSignal.h>，才能使用RACReturnSignal。
bind方法使用步骤:
1. 传入一个返回值RACStreamBindBlock的block。
2. 描述一个RACStreamBindBlock类型的bindBlock作为block的返回值。
3. 描述一个返回结果的信号，作为bindBlock的返回值。
4. 在bindBlock中做信号结果的处理。

代码举例1
需求: 假设想监听文本框的内容，并且在每次输出结果的时候，都在文本框的内容拼接一段文字“输出：”

 -(void)viewDidLoad{
 UITextField *textField = [[UITextField alloc] initWithFrame:CGRectMake(100, 100, 200, 30)];
 textField.backgroundColor = [UIColor redColor];
 [self.view addSubview:textField];
 UILabel *label = [[UILabel alloc] init];
 label.frame = CGRectMake(100, 300, 200, 30);
 [self.view addSubview: label];
    
 //方法1:
 [textField.rac_textSignal subscribeNext:^(NSString * _Nullable x) {
     NSLog(@"输出:%@",x);
 }];
 // 方式二:在返回结果前，拼接，使用RAC中bind方法做处理。
 //1.绑定信号
 RACSignal *bindSignal = [textField.rac_textSignal bind:^RACSignalBindBlock _Nonnull{
     //当前block的调用时刻:绑定的信号(textField.rac_textSignal)被订阅时调用
     // block作用:表示绑定了一个信号.
     return ^RACSignal *(id value, BOOL *stop){
         // 什么时候调用block:只要源信号(textField.rac_textSignal)发送数据，就会来到这个block。
         // block作用:处理源信号的内容
         //value:源信号发送的内容
         // 做好处理，通过信号返回出去.
         value = [NSString stringWithFormat:@"输出:%@",value];
         //返回信号不能传nil,可以返回空信号[RACSignal empty];
         // return nil;
         //包装信号返回出去
         return [RACReturnSignal return:value];
     };
 }];
 //2.订阅绑定信号
 [bindSignal subscribeNext:^(id  _Nullable x) {
     //block调用时刻:当处理完信号发送数据的时候,就回调用这个block
      NSLog(@"%@",x);
 }];
 }

代码举例2:

 - (void)test {
 //1.创建信号
 RACSubject *sourceSignal = [RACSubject subject];
 //2. 绑定信号
 RACSignal *bindSignal = [sourceSignal bind:^RACSignalBindBlock _Nonnull{
        
     return ^RACSignal *(id value, BOOL *stop){
            
         value = [NSString stringWithFormat:@"在这里处理源信号:%@",value];
            
         return [RACReturnSignal return:value];
     };
 }];
 //3.订阅绑定信号
 [bindSignal subscribeNext:^(id  _Nullable x) {
     NSLog(@"%@",x);
 }];
 //4. 发送数据
 [sourceSignal sendNext:@"123"];
 }

这两个例子体现的hook思想:
1. 任意一个信号,只要被绑定(bind),一旦发出数据信号,我们就能拿到这个信号进行处理,然后返回处理完的信号,当订阅拿到这个信号时,已经是改变后的信号

底层实现

bind:方法内部简析:

  方法简化如下:
  - (RACSignal *)bind:(RACSignalBindBlock (^)(void))block {
 
 //定义addSignal一个block
  void (^addSignal)(RACSignal *) = ^(RACSignal *signal) {
 
 //7. 订阅returnsignal
   //这个signal是RACReturnSignal,调用subscribeNext:
     //7.1. 内部会创建一个订阅者subscriber,保存nextblock
     //7.2. 调用RACReturnSignal类的 :[self subscribe:o]
     //7.3. 注意:是RACReturnSignal类的!!!,该方法内部会主动使用该订阅者发送信号,调用外部的nextblock
     /* - (RACDisposable *)subscribe:(id<RACSubscriber>)subscriber {
      return [RACScheduler.subscriptionScheduler schedule:^{
      [subscriber sendNext:self.value];
      [subscriber sendCompleted];
      }];
      }*/
 
 RACDisposable *disposable = [signal subscribeNext:^(id x) {
 
 //8. 发送信号bindsignal,将处理数据传出去
 //9. 调用外部bindsignal的nextblock
 //这个subscriber是bindsignal的订阅者
 
 [subscriber sendNext:x];
 
      } error:^(NSError *error) {
      } completed:^{
      }];
     };
 
    // 1.创建bindsignal
     return [[RACSignal createSignal:^(id<RACSubscriber> subscriber) {
 
     //2.调用外部传进的block,返回RACSignalBindBlock
     RACSignalBindBlock bindingBlock = block();
 
     //3.内部订阅源信号
     RACDisposable *bindingDisposable = [self subscribeNext:^(id x) {
 
             //4. 外部源信号发送数据,来到这里
             // 5. 调用外部的bindingBlock,获得(处理后的信号)returnsignal
             BOOL stop = NO;
             id signal = bindingBlock(x, &stop);
 
             //6.调用自定义的addSignalblock
             if (signal != nil) addSignal(signal);
 
             } error:^(NSError *error) {
             } completed:^{
         }];
     }
     return compoundDisposable;
     }]];
 }

结论
1. 源信号调用bind,会返回重新创建(create)的一个绑定信号RACSignal(bindsignal)。
2. 当绑定信号(bindsignal)被订阅,就会调用绑定信号中的didSubscribe
  1. 调用bind:传入的block,返回一个bindingBlock(RACSignalBindBlock)。
  2. 内部订阅外部的源信号,nextBlock
3. 当源信号有内容发出(发送信号)，调用bind内部的订阅nextBlock
  1. 调用bindingBlock,外部block实现中进行处理,并返回处理后的信号(RACReturnSignal)signal
  2. 调用内部定义的addSignal这个block,将returnsignal传入
    1. 订阅returnsignal,这个returnsignal是RACReturnSignal
      1. 内部会创建一个订阅者subscriber,保存nextblock
      2. 调用RACReturnSignal类的 :[self subscribe:o]
      3. 注意:是RACReturnSignal类的!!!,该方法内部会主动使用该订阅者发送信号,调用外部的nextblock
    2. nextblock内部调用:[subscriber sendNext:x];
    3. 注意:这个subscriber是bindsignal的订阅者
4. 调用外部订阅bindSignal的nextblock,拿到改变后的值

ReactiveCocoa核心操作方法之映射(`flattenMap,Map`)

作用: 把源信号内容映射成新的内容。

flattenMap

作用:把源信号的内容映射成一个新的信号，信号可以是任意类型。
flattenMap使用步骤:
1. 传入一个block，block类型是返回值RACSignal，参数value
2. 参数value就是源信号的内容，拿到源信号的内容做处理
3. 包装成RACReturnSignal信号，返回出去。

举例使用

//1. 映射信号
RACSignal *mapSignal = [_textField.rac_textSignal flattenMap:^__kindof RACSignal * _Nullable(NSString * _Nullable value) {
    // block什么时候 : 源信号发出的时候，就会调用这个block。
    // block作用 : 改变源信号的内容。
    // value:就是源信号发送的数据
    // 返回值：绑定信号的内容.
    return [RACReturnSignal return:[NSString stringWithFormat:@"输出:%@",value]];
}];
//2. 订阅信号
[mapSignal subscribeNext:^(id  _Nullable x) {
    // 订阅绑定信号，每当源信号发送内容，做完处理，就会调用这个block。
    NSLog(@"====%@",x);
}];

底层实现
1. 主要是对bind做一层封装
2. flattenMap中block的返回值，会作为bind中bindBlock的返回值(数据的处理放在了flattenMap的block中)。
3. 调用bindBlock，内部就会调用flattenMap的block，flattenMap的block作用：就是把处理好的数据包装成信号。
4. 返回的信号最终会作为bindBlock中的返回信号，当做bindBlock的返回信号。
5. 订阅bindBlock的返回信号，就会拿到绑定信号的订阅者，把处理完成的信号内容发送出来。

Map

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

代码举例:

 [[_textField.rac_textSignal map:^id(id value) {
     // 当源信号发出，就会调用这个block，修改源信号的内容
     // 返回值：就是处理完源信号的内容。
     return [NSString stringWithFormat:@"输出:%@",value];
 }] subscribeNext:^(id x) {
        
     NSLog(@"%@",x);
 }];

底层实现
1. 主要是对flatternMap的进一步封装
2. Map中block中的返回的值会作为flatternMap中block中的值。
3. 当订阅绑定信号，就会生成bindBlock。
4. 当源信号发送内容，就会调用bindBlock(value, *stop)
5. 调用bindBlock，内部就会调用flattenMap的block
6. flattenMap的block内部会调用Map中的block，把Map中的block返回的内容包装成返回的信号。
7. 返回的信号最终会作为bindBlock中的返回信号，当做bindBlock的返回信号。
8. 订阅bindBlock的返回信号，就会拿到绑定信号的订阅者，把处理完成的信号内容发送出来。

FlatternMap和Map的区别

FlatternMap中的Block返回信号。
Map中的Block返回对象。
开发中，如果信号发出的值不是信号，映射一般使用Map
开发中，如果信号发出的值是信号，映射一般使用FlatternMap。
signalOfsignals用FlatternMap。

代码举例:

 // 创建信号中的信号
 RACSubject *signalOfsignals = [RACSubject subject];
 RACSubject *signal = [RACSubject subject];

 [[signalOfsignals flattenMap:^RACStream *(id value) {

  // 当signalOfsignals的signals发出信号才会调用

     return value;

 }] subscribeNext:^(id x) {

     // 只有signalOfsignals的signal发出信号才会调用，因为内部订阅了bindBlock中返回的信号，也就是flattenMap返回的信号。
     // 也就是flattenMap返回的信号发出内容，才会调用。

     NSLog(@"%@aaa",x);
 }];

 // 信号的信号发送信号
 [signalOfsignals sendNext:signal];

 // 信号发送内容
 [signal sendNext:@1];
    

ReactiveCocoa操作方法之组合

contact

作用:按一定顺序拼接信号，当多个信号发出的时候，有顺序的接收信号。

代码举例:

 //1. 创建信号1
 RACSignal *signalA = [RACSubject createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
    //发送网络请求
     NSLog(@"网络请求1");
     //发送信号(将请求的数据发送出去)
     [subscriber sendNext:@"网络请求1的数据"];
     [subscriber sendCompleted];
     return nil;
 }];
 //2.创建信号B
 RACSignal *signalB = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
     //发送网络请求
     NSLog(@"网络请求2");
     //发送信号(将请求的数据发送出去)
     [subscriber sendNext:@"网络请求2的数据"];
     [subscriber sendCompleted];
     return nil;
 }];
 //把signalA拼接到signalB后面,signalA发送完成,signalB才会被激活
 //注意：第一个信号必须发送完成，第二个信号才会被激活,即:第一个信号必须要调用 [subscriber sendCompleted];
 // 以后只需要面对拼接信号开发。
 // 订阅拼接的信号，不需要单独订阅signalA，signalB
 // 内部会自动订阅。
 //3. 创建组合信号
 RACSignal *contactSignal = [signalA concat:signalB];
 //4. 订阅信号
 [contactSignal subscribeNext:^(id  _Nullable x) {
     NSLog(@"%@",x);
 }];

底层实现
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中发送值,就会通过拼接信号的订阅者把值发送出来.

then

作用: 用于连接两个信号，当第一个信号完成，才会连接then返回的信号。
注意:使用then，之前信号的值会被忽略掉.

代码举例:

  //1. 创建信号1
 RACSignal *signalA = [RACSubject createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
     //发送网络请求
     NSLog(@"网络请求1");
     //发送信号(将请求的数据发送出去)
     [subscriber sendNext:@"网络请求1的数据"];
     [subscriber sendCompleted];
     return nil;
 }];
 //2.创建信号B
 RACSignal *signalB = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
     //发送网络请求
     NSLog(@"网络请求2");
     //发送信号(将请求的数据发送出去)
     [subscriber sendNext:@"网络请求2的数据"];
     [subscriber sendCompleted];
     return nil;
 }];
 [[signalA then:^RACSignal *{
     return signalB;
 }] subscribeNext:^(id x) {
        
     // 只能接收到第二个信号的值，也就是then返回信号的值
     NSLog(@"%@",x);
 }];

底层实现
1. 先过滤掉之前的信号发出的值
2. 使用concat连接then返回的信号
与contact的区别
1. contact会传出每个网络请求的值
2. then会过滤掉第一个网络请求的值

merge

作用: 把多个信号合并为一个信号，任何一个信号有新值的时候就会调用

代码举例:

 // merge:把多个信号合并成一个信号
 //当有多个网络请求时,哪个先请求,哪个先调用
 //创建多个信号
 RACSignal *signalA = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
        
     [subscriber sendNext:@1];
        
        
     return nil;
 }];
    
 RACSignal *signalB = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
        
     [subscriber sendNext:@2];
        
     return nil;
 }];
    
 // 合并信号,任何一个信号发送数据，都能监听到.
 RACSignal *mergeSignal = [signalA merge:signalB];
    
 [mergeSignal subscribeNext:^(id x) {
        
     NSLog(@"%@",x);
        
 }];

底层实现：
1. 合并信号被订阅的时候，就会遍历所有信号，并且发出这些信号。
2. 每发出一个信号，这个信号就会被订阅
3. 也就是合并信号一被订阅，就会订阅里面所有的信号。
4. 只要有一个信号被发出就会被监听。

zipWith

作用: 把两个信号压缩成一个信号，只有当两个信号同时发出信号内容时，并且把两个信号的内容合并成一个元组，才会触发压缩流的next事件。

代码举例:

 RACSubject *signalA = [RACSubject subject];
 RACSubject *signalB =  [RACSubject subject];
    
 //当一个界面多个网络请求的时候,要等到所有请求都完成才能更新UI
    
 // 压缩信号A，信号B
 RACSignal *zipSignal = [signalA zipWith:signalB];
    
 [zipSignal subscribeNext:^(id x) {
     //x是一个元组,x中的排列顺序与组合顺序相同
     NSLog(@"%@",x);
 }];
 //仅仅A发送时不会触发的
 [signalA sendNext:@1];
 [signalB sendNext:@2];

底层实现
1. 定义压缩信号，内部就会自动订阅signalA，signalB
2. 每当signalA或者signalB发出信号，就会判断signalA，signalB有没有发出个信号，有就会把最近发出的信号都包装成元组发出。

combineLatest/reduce

combineLatest 组合
1. 作用: 将多个信号合并起来，并且拿到各个信号的最新的值,必须每个合并的signal至少都有过一次sendNext，才会触发合并的信号。
2. 单独使用功能跟zipWith一样
  1. 与zipWith区别:
    1. zipWith两者同时发送信号才能订阅到值
    2. combineLatest任意一个发送信号都能订阅到
3. 底层实现:
  1. 当组合信号被订阅，内部会自动订阅signalA，signalB,必须两个信号都发出内容，才会被触发。
  2. 并且把两个信号组合成元组发出。
reduce 聚合
1. 作用: 用于信号发出的内容是元组，把信号发出元组的值聚合成一个值
2. 常见用法:先组合再聚合
```
 //NSFastEnumeration:就是数组的意思
 combineLatest:(id<NSFastEnumeration>)signals reduce:(id (^)())reduceBlock
```
3. reduce中的block简介:
  1. reduceblcok中的参数，有多少信号组合，reduceblcok就有多少参数，每个参数就是之前信号发出的内容
  2. reduceblcok的返回值：聚合信号之后的内容。
4. 底层实现:
  1. 订阅聚合信号，每次有内容发出，就会执行reduceblcok，把信号内容转换成reduceblcok返回的值。

代码举例:
需求:当”手机号”与”密码”都有值是,”登录”使能,将三个控件分别拖到控制器属性中

  RACSignal *combineSignal = [RACSignal combineLatest:@[self.phoneTextField.rac_textSignal,self.passWordTextField.rac_textSignal] reduce:^id _Nullable(NSString *account , NSString *pwd){
     //NSString *account , NSString *pwd : 这些参数有组合信号发出的内容而定
     //block调用: 只要原信号发送内容就会调用,组合成一个新值
     NSLog(@"%@===%@",account,pwd);
     //聚合的值,就是组合信号的内容
     return @(account.length&&pwd.length);
 }];
 //订阅聚合信号
 //方法1:
 [combineSignal subscribeNext:^(id  _Nullable x) {
     self.loginBtn.enabled = [x boolValue];
 }];
 //方法2:
//    RAC(self.loginBtn,enabled) = combineSignal;

ReactiveCocoa操作方法之过滤

filter

过滤信号，使用它可以获取满足条件的信号.

代码举例:

 //只有文本框的长度大于5才获取值
 [[_textField.rac_textSignal filter:^BOOL(NSString * _Nullable value) {
     //返回值,就是过滤条件,只有满足这个条件才能获取到内容
     return value.length > 5;
 }] subscribeNext:^(NSString * _Nullable x) {
    //文本框的内容
     NSLog(@"%@",x);
 }];

ignore

作用: 忽略完某些值的信号.(忽略一些值)
ignoreValues: 忽略所有值

代码举例

 RACSubject *subject = [RACSubject subject];
 //忽略一些值
 RACSignal *ignoreSignal = [subject ignore:@1];
 //忽略所有值
//    [subject ignoreValues];
 //订阅信号
 [ignoreSignal subscribeNext:^(id  _Nullable x) {
     NSLog(@"%@",x);
 }];
 //发送信号
 //会被忽略掉
 [subject sendNext:@1];
 [subject sendNext:@123];

take

作用: 取前面几个值,从开始一共取N次信号

代码举例

 RACSubject *subject = [RACSubject subject];
 //忽略一些值
 RACSignal *takeSignal = [subject take:1];
 //订阅信号
 [takeSignal subscribeNext:^(id  _Nullable x) {
     NSLog(@"%@",x);
 }];
 //发送信号
 //只取第一个
 [subject sendNext:@1];
 [subject sendNext:@123];

takeLast

取最后N次的信号,前提条件，订阅者必须调用完成，因为只有完成，就知道总共有多少信号.

代码举例:

 RACSubject *subject = [RACSubject subject];
 //只会取倒数第一个值
 RACSignal *takeLastSignal = [subject takeLast:1];
 //订阅信号
 [takeLastSignal subscribeNext:^(id  _Nullable x) {
     NSLog(@"%@",x);
 }];
 //发送信号
 //只取倒数第一个
 [subject sendNext:@1];
 [subject sendNext:@123];
 [subject sendCompleted];

takeUntil

作用: 获取信号直到某个信号执行完成

代码举例:

 //例1:
 // 监听文本框的改变直到当前对象被销毁
 [[_textField.rac_textSignal takeUntil:self.rac_willDeallocSignal] subscribeNext:^(NSString * _Nullable x) {
     NSLog(@"%@",x);
 }];
    
 //例2:
 //监听信号subject知道subject1发送完成
 RACSubject *subject1 = [RACSubject subject];
 RACSubject *subject = [RACSubject subject];
 [[subject takeUntil:subject1] subscribeNext:^(id  _Nullable x) {
     NSLog(@"%@",x);
 }];
 [subject sendNext:@1];
 [subject sendNext:@2];
 //一旦信号1发送完成,就不会在订阅subject信号
 [subject1 sendCompleted];
 //不会在订阅了
 [subject sendNext:@3];

distinctUntilChanged

作用: 如果当前的值跟上一个的值一样,就不会被订阅到(当上一次的值和当前的值有明显的变化就会发出信号，否则会被忽略掉。)

代码举例:

  // 过滤，当上一次和当前的值不一样，就会发出内容。
// 在开发中，刷新UI经常使用，只有两次数据不一样才需要刷新
[[_textField.rac_textSignal distinctUntilChanged] subscribeNext:^(id x) {
        
    NSLog(@"%@",x);
}];
    

skip

作用: 跳过几个信号,不接收。

代码举例;

 // 表示输入第一次，不会被监听到，跳过第一次发出的信号
 [[_textField.rac_textSignal skip:1] subscribeNext:^(id x) {
       
     NSLog(@"%@",x);
 }];

switchToLatest

作用: 用于signalOfSignals（信号的信号），有时候信号也会发出信号，会在signalOfSignals中，获取signalOfSignals发送的最新信号。

代码举例:

 RACSubject *signalOfSignals = [RACSubject subject];
RACSubject *signal = [RACSubject subject];
    
 // 获取信号中信号最近发出信号，订阅最近发出的信号。
 // 注意switchToLatest：只能用于信号中的信号
 [signalOfSignals.switchToLatest subscribeNext:^(id x) {
       
     NSLog(@"%@",x);
 }];
 [signalOfSignals sendNext:signal];
 [signal sendNext:@1];

ReactiveCocoa操作方法之秩序

doNext: 执行Next之前，会先执行这个Block
doCompleted: 执行sendCompleted之前，会先执行这个Block

代码举例

 [[[[RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
     [subscriber sendNext:@1];
     [subscriber sendCompleted];
     return nil;
 }] doNext:^(id x) {
     // 执行[subscriber sendNext:@1];之前会调用这个Block
     NSLog(@"doNext");;
 }] doCompleted:^{
     // 执行[subscriber sendCompleted];之前会调用这个Block
     NSLog(@"doCompleted");;
        
 }] subscribeNext:^(id x) {
        
     NSLog(@"%@",x);
 }];

ReactiveCocoa操作方法之线程

deliverOn: 内容传递切换到制定线程中，副作用在原来线程中,把在创建信号时block中的代码称之为副作用。
subscribeOn: 内容传递和副作用都会切换到制定线程中。

ReactiveCocoa操作方法之时间

timeout

作用: 超时，可以让一个信号在一定的时间后，自动报错。

代码举例:

  RACSignal *signal = [[RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
     return nil;
 }] timeout:1 onScheduler:[RACScheduler currentScheduler]];
    
 [signal subscribeNext:^(id x) {
     NSLog(@"%@",x);
 } error:^(NSError *error) {
     // 1秒后会自动调用
     NSLog(@"%@",error);
 }];

interval

作用: 定时,每隔一段时间发出信号

代码举例:

[[RACSignal interval:1 onScheduler:[RACScheduler currentScheduler]] subscribeNext:^(id x) {
        
     NSLog(@"%@",x);
 }];

delay

作用: 延迟发送next。

代码举例

 RACSignal *signal = [[[RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
   
 [subscriber sendNext:@1];
 return nil;
 }] delay:2] subscribeNext:^(id x) {
      
     NSLog(@"%@",x);
 }];

ReactiveCocoa操作方法之重复

retry

作用: 重试,只要失败，就会重新执行创建信号中的block,直到成功.

代码举例:

 __block int i = 0;
 [[[RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
        
     if (i == 10) {
         [subscriber sendNext:@1];
     }else{
         NSLog(@"接收到错误");
         [subscriber sendError:nil];
     }
     i++;
     return nil;
        
 }] retry] subscribeNext:^(id x) {
        
     NSLog(@"%@",x);
 } error:^(NSError *error) {
 }];

replay

重放,当一个信号被多次订阅,反复播放内容

代码举例:

 RACSignal *signal = [[RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {

     [subscriber sendNext:@1];
     [subscriber sendNext:@2];
        
     return nil;
 }] replay];
    
 [signal subscribeNext:^(id x)   {
     NSLog(@"第一个订阅者%@",x);
        
 }];
    
 [signal subscribeNext:^(id x) {
     NSLog(@"第二个订阅者%@",x);
        
 }];

throttle

作用: 节流,当某个信号发送比较频繁时，可以使用节流，在某一段时间不发送信号内容，过了一段时间获取信号的最新内容发出。

代码举例:

 RACSubject *signal = [RACSubject subject];
    
 _signal = signal;
    
 // 节流，在一定时间（1秒）内，不接收任何信号内容，过了这个时间（1秒）获取最后发送的信号内容发出。
 [[signal throttle:1] subscribeNext:^(id x) {
        
     NSLog(@"%@",x);
 }];
 [signal sendNext:@"3"];

RAC系列3之 常见的操作方法

ReactiveCocoa常见操作方法

ReactiveCocoa核心操作方法之绑定(bind )

ReactiveCocoa核心操作方法之映射(flattenMap,Map)

flattenMap

Map

FlatternMap和Map的区别

ReactiveCocoa操作方法之组合

contact

then

merge

zipWith

combineLatest/reduce

ReactiveCocoa操作方法之过滤

filter

ignore

take

takeLast

takeUntil

distinctUntilChanged

skip

switchToLatest

ReactiveCocoa操作方法之秩序

ReactiveCocoa操作方法之线程

ReactiveCocoa操作方法之时间

timeout

interval

delay

ReactiveCocoa操作方法之重复

retry

replay

throttle

RAC系列3之常见的操作方法

ReactiveCocoa核心操作方法之绑定(`bind` )

ReactiveCocoa核心操作方法之映射(`flattenMap,Map`)