RAC使用
不介绍RAC是啥了，直接上干货
基础用法
- 创建信号及发送内容
// 创建信号
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;
}];
- 订阅信号
// 完整用法
[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:^{
}];
-
信号的其他创建方式
- 返回一个空信号 [RACSignal empty]
- 将普通值包装为信号 [RACSignal return:@1]
- 包装错误 [RACSignal error:nil]
- 通过RACSubject发送信号
RACSubject *subject = [RACSubject subject]; [subject sendNext:@1]; [subject sendCompleted];
高阶函数
列举一些常用的高级函数
- 过滤
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
)
- 转换
普通类型转换（返回普通对象）
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];
}];
}];
常用用法
- 绑定
RAC(self.stateLabel,text) = [RACObserve(self.viewModel, stateText) deliverOnMainThread];
- 延迟执行
[RACScheduler.scheduler afterDelay:5 schedule:^{
}];
- 抖动，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];
}];
- merge: 来一个更新一个
[[RACSignal merge:@[signal1,signal2]] subscribeNext:^(id _Nullable x) {
}];
- zip: 都来了进行打包，没次打包都需要各个信号发送完才能打包,next是元祖，元祖内的顺序是根据zip顺序
[[RACSignal zip:@[signal1,signal2]] subscribeNext:^(RACTuple * _Nullable x) {
}];
- takeUntil 满足条件时终止订阅
注意事项
最需要注意的就是内存管理。
- RAC的任何一个block，包括使用调度器，在使用self都要weak 和 strong搭配使用，否则会造成内存泄漏，对象无法释放，或者延迟释放。
- 信号一定要能结束，正常结束或者抛出错误都可以，不结束的信号无法释放
- 一般情况下信号处理完会自动释放，必要时可以主动dispose来释放资源，总之要及时释放
- 懒加载的weak 和 strong 应在 判断之前weak，在使用的时候strong
