RAC使用

不介绍RAC是啥了，直接上干货

基础用法

1. 创建信号及发送内容

// 创建信号
    RACSignal *signal = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        
        // 发送信号
        [subscriber sendNext:@1];
        [subscriber sendNext:@2];
        // ....
        
        // 通过subscribeOn来正常结束信号
        [subscriber sendCompleted];
        
        // 或者sendError来抛出错误
        [subscriber sendError:nil];
        
        // 不管是sendCompleted 或者sendError 都会使信号结束，信号结束后再发送信号，是收不到的
        
        [subscriber sendNext:@3];
        NSLog(@"不管怎样，都结束了");
        
        return [RACDisposable disposableWithBlock:^{
           // 释放资源
        }];
        
        // 不需要释放，也可以直接return nil
//        return nil;
    }];

1. 订阅信号

// 完整用法
    [signal subscribeNext:^(id  _Nullable x) {
        NSLog(@"收到信号:%@",x);
    } error:^(NSError * _Nullable error) {
        NSLog(@"收到了错误:%@",error);
    } completed:^{
        NSLog(@"收到了完成");
    }];
// 控制台输出
2022-08-04 14:46:15.640111+0800 RAC[73753:3400797] 收到信号:1
2022-08-04 14:46:15.640249+0800 RAC[73753:3400797] 收到信号:2
2022-08-04 14:46:15.640366+0800 RAC[73753:3400797] 收到了完成
2022-08-04 14:46:15.640472+0800 RAC[73753:3400797] 不管怎样，都结束了

如果只关注单个或者部分，也可以使用其他的快捷方法

// 同时关注 next和错误
    [signal subscribeNext:^(id  _Nullable x) {
        
    } error:^(NSError * _Nullable error) {
        
    }];
  
    // 同时关注 next和完成
    [signal subscribeNext:^(id  _Nullable x) {
        
    } completed:^{
        
    }];
    
    // 只关注next事件
    [signal subscribeNext:^(id  _Nullable x) {
            
    }];
    
    // 只关注错误事件
    [signal subscribeError:^(NSError * _Nullable error) {
            
    }];
    
    // 只关注正常完成事件
    [signal subscribeCompleted:^{
            
    }];

1. 信号的其他创建方式

   1. 返回一个空信号 [RACSignal empty]
   2. 将普通值包装为信号 [RACSignal return:@1]
   3. 包装错误 [RACSignal error:nil]
   4. 通过RACSubject发送信号

   RACSubject *subject = [RACSubject subject]; 
   [subject sendNext:@1]; 
   [subject sendCompleted];
   

高阶函数

列举一些常用的高级函数

1. 过滤

NSArray *originArray =@[@1,@2,@3,@4,@5];
    NSArray *result = [originArray.rac_sequence.signal filter:^BOOL(id  _Nullable value) {
        // 过滤出所有的偶数
        return [value intValue] % 2;
    }].toArray;
    NSLog(@"result:%@",result);
//打印
2022-08-04 15:54:48.871304+0800 RAC[19881:3535507] result:(
    1,
    3,
    5
)

1. 转换

普通类型转换（返回普通对象）

NSArray *originArray =@[@1,@2,@3,@4,@5];
    NSArray *result;
    result = [originArray.rac_sequence.signal map:^id _Nullable(id  _Nullable value) {
         return [NSString stringWithFormat:@"fileName__%@",value];
     }].toArray;
     NSLog(@"result:%@",result);
// 打印
2022-08-04 16:01:24.316079+0800 RAC[24563:3551828] result:(
    "fileName__1",
    "fileName__2",
    "fileName__3",
    "fileName__4",
    "fileName__5"
)

信号类型转换（返回信号）

NSArray *originArray =@[@1,@2,@3,@4,@5];
    NSArray *result;
    result = [originArray.rac_sequence.signal flattenMap:^__kindof RACSignal * _Nullable(id  _Nullable value) {
        return [RACSignal return:[NSString stringWithFormat:@"fileName__%@",value]];
    }].toArray;
    NSLog(@"result:%@",result);
// 打印
2022-08-04 16:06:02.043072+0800 RAC[27840:3563788] result:(
    "fileName__1",
    "fileName__2",
    "fileName__3",
    "fileName__4",
    "fileName__5"
)

通过返回信号，可以方便的跟其他信号进行组合。

比如，实际运行中的一个例子,先下载文件，下载文件后进行解析

        NSLog(@"1.下载vcf文件");
        NSDictionary *params = @{@"path":self.record.filePath};
    RACSignal *downLoadSignal  = [self.viewModel.getBackupRecordFileCommand execute:params];
    // A2. 解析
                @weakify(self);
    RACSignal *parseSignal = [downLoadSignal flattenMap:^__kindof RACSignal * _Nullable(NSURL * value) {
        NSLog(@"2.解析vcf文件");
        @strongify(self);
        return [self.viewModel paraseVCFWithFile:value];
    }];

多线程处理

使用RACScheduler调度器，调度器 是对GCD的进一步封装，

常见操作有：

在主线程执行某任务

[RACScheduler.mainThreadScheduler schedule:^{
        NSLog(@"在主线程执行任务");
    }];

在子线程执行任务

[RACScheduler.currentScheduler schedule:^{
        NSLog(@"在子线程执行任务");
    }];

还可以指定线程优先级及线程名称

[[RACScheduler schedulerWithPriority:RACSchedulerPriorityDefault name:@"com.test.hardword"] schedule:^{
        NSLog(@"使用子线程处理任务，并给线程进行命名");
    }];

订阅时，直接将事件切换到主线程或者子线程

RACSignal *mySiganl = [RACSignal return:@"Hello"];
    [[mySiganl deliverOnMainThread] subscribeNext:^(id  _Nullable x) {
            // 这里的代码在主线程执行
    }];
    
    [[mySiganl deliverOn:RACScheduler.scheduler] subscribeNext:^(id  _Nullable x) {
       // 这里的代码在子线程执行
    }];

指定任务在子线程执行，创建的时候最好开辟一条线程，负责 在哪个线程调用就会在哪个线程执行

[RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
      return [RACScheduler.scheduler schedule:^{
          NSLog(@"[信号]创建信号,当前线程:%@",NSThread.currentThread);
          [subscriber sendNext:@1];
          [subscriber sendCompleted];
       }];
   }];

常用用法

1. 绑定

RAC(self.stateLabel,text) = [RACObserve(self.viewModel, stateText) deliverOnMainThread];

1. 延迟执行

[RACScheduler.scheduler afterDelay:5 schedule:^{
                  
                }];

1. 抖动，throttle，在指定时间内只触发一次

[[[[[[NSNotificationCenter.defaultCenter rac_addObserverForName:CNContactStoreDidChangeNotification object:nil]
        takeUntil:self.rac_willDeallocSignal]
        throttle:2]
       filter:^BOOL(NSNotification * _Nullable value) {
        NSNumber *exernal = value.userInfo[@"CNNotificationOriginationExternally"];
        return exernal.integerValue == 1;
    }] throttle:1] subscribeNext:^(id  _Nullable x) {
        @strongify(self);
        NSLog(@"联系人已经更新，需要更新数据");
        [self.viewModel.queryCurrentContactCountCommand execute:nil];
    }];

1. merge: 来一个更新一个

[[RACSignal merge:@[signal1,signal2]] subscribeNext:^(id  _Nullable x) {
        
    }];

1. zip: 都来了进行打包，没次打包都需要各个信号发送完才能打包,next是元祖，元祖内的顺序是根据zip顺序

[[RACSignal zip:@[signal1,signal2]] subscribeNext:^(RACTuple * _Nullable x) {
        
    }];

1. takeUntil 满足条件时终止订阅

注意事项

最需要注意的就是内存管理。

1. RAC的任何一个block，包括使用调度器，在使用self都要weak 和 strong搭配使用，否则会造成内存泄漏，对象无法释放，或者延迟释放。
2. 信号一定要能结束，正常结束或者抛出错误都可以，不结束的信号无法释放
3. 一般情况下信号处理完会自动释放，必要时可以主动dispose来释放资源，总之要及时释放
4. 懒加载的weak 和 strong 应在 判断之前weak，在使用的时候strong