这个方法是说明的例子 下边会用到很多次
//模拟请求网络的操作
-(void)loadNetWorkData:(void(^)(id data))success{
success(@"成功");
}
1:RACMulticastConnection
解决问题：避免多次订阅一个信号 执行多次信号block内部的代码
项目中的实战：对一个网络请求的信号多次订阅造成多次请求
//避免因为订阅多次 导致 信号执行多次
-(void)multicastConnection{
RACSignal *signal = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber> _Nonnull subscriber) {
[self loadNetWorkData:^(id data) {
NSLog(@"测试执行次数 --- %@",data);
[subscriber sendNext:data];
}];
return nil;
}];
RACMulticastConnection *connection = [signal publish];
[connection.signal subscribeNext:^(id _Nullable x) {
NSLog(@"订阅1 --- %@",x);
}];
[connection.signal subscribeNext:^(id _Nullable x) {
NSLog(@"订阅2 --- %@",x);
}];
[connection.signal subscribeNext:^(id _Nullable x) {
NSLog(@"订阅3 --- %@",x);
}];
[connection connect];
}
2:RACCommand
解决问题： 可以获取到信号的执行过程.
项目实战：获取网络数据 直接在ViewModel 中用RACCommand封装，然后在ViewController中拿到执行的状态 对请求状态进行操作
坑：
1：订阅信号 executionSignals 要在 execute 方法之前
2：发送完信号 要发送 sendCompleted 不然command.executing无法接收到信号停止
-(void)commandRAC{
RACCommand *commond = [[RACCommand alloc] initWithSignalBlock:^RACSignal * _Nonnull(id _Nullable input) {
NSLog(@"1:开始执行input ---- %@",input);
return [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber> _Nonnull subscriber) {
[subscriber sendNext:@"345"];
[subscriber sendCompleted];
return nil;
}];
}];
[commond.executionSignals.switchToLatest subscribeNext:^(id _Nullable x) {
NSLog(@"3:拿到最新的信号 --- %@",x);
}];
[commond execute:@"执行的传值"];
//跳过第一次 [commond.executing skip:1];
[[commond.executing skip:1] subscribeNext:^(NSNumber * _Nullable x) {
BOOL isExecuting = [x boolValue];
if (isExecuting) {
NSLog(@"2:commond 正在执行");
}else{
NSLog(@"4:commond 执行结束");
}
}];
}
3: rac_liftSelector
功能： 可以检测到几个信号全部执行完载执行接下来的方法
项目实战：解决UI展示需要多个接口执行完才能继续执行接下来的方法！（还可以通过GCD的线程组完成 不过这个更直观点）
坑：
[self rac_liftSelector:@selector(reloadComplationDataA:dataB:) withSignalsFromArray:@[signalA,signalB]];
载执行 上边 @selector()方法的时候有几个信号就需要几个参数
-(void)waitingLoadAllData{
@weakify(self);
RACSignal *signalA = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber> _Nonnull subscriber) {
@strongify(self);
//延迟三秒做操作
dispatch_after(dispatch_time(DISPATCH_TIME_NOW, (int64_t)(3 * NSEC_PER_SEC)), dispatch_get_main_queue(), ^{
[self loadNetWorkData:^(id data) {
NSLog(@"第一个网络请求结束--%@",data);
[subscriber sendNext:@"data"];
}];
});
return nil;
}];
RACSignal *signalB = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber> _Nonnull subscriber) {
@strongify(self);
[self loadNetWorkData:^(id data) {
NSLog(@"第二个网络请求结束--%@",data);
[subscriber sendNext:@"data"];
}];
return nil;
}];
[self rac_liftSelector:@selector(reloadComplationDataA:dataB:) withSignalsFromArray:@[signalA,signalB]];
}
-(void)reloadComplationDataA:(id)dataA dataB:(id)dataB{
NSLog(@"全部请求完成");
}
2019-05-07 16:04:00.107081+0800 第二个网络请求结束--成功
2019-05-07 16:04:03.107146+0800 第一个网络请求结束--成功
2019-05-07 16:04:03.107364+0800 全部请求完成
4:信号之间的依赖 then
功能： 执行完本次信号的操作再去执行下一个操作
项目实战：执行完本次网络操作 才能接着执行下次网络操作，类似京东的分类页面。需要父分类的 id 才去请求父分类下子分类的数据
避免了 block 的循环嵌套操作
-(void)replyonOtherSignal{
[[[self loadCatagory] then:^RACSignal * _Nonnull{
return [self loadDetail];
}] subscribeNext:^(id _Nullable x) {
NSLog(@"完成 ---- %@",x);
}];
}
-(RACSignal *)loadCatagory{
RACSubject *signa = [RACReplaySubject subject];
dispatch_after(dispatch_time(DISPATCH_TIME_NOW, (int64_t)(3 * NSEC_PER_SEC)), dispatch_get_main_queue(), ^{
[self loadCatagoryData:^(id data) {
NSLog(@"加载分类完成 ---- %@",data);
[signa sendNext:data];
[signa sendCompleted];
}];
});
return signa;
}
-(RACSignal *)loadDetail{
RACSubject *signa = [RACReplaySubject subject];
[self loadCatagoryDetail:^(id data) {
//模拟延迟加载
dispatch_after(dispatch_time(DISPATCH_TIME_NOW, (int64_t)(3 * NSEC_PER_SEC)), dispatch_get_main_queue(), ^{
NSLog(@"加载详情完成 ---- %@",data);
[signa sendNext:data];
});
}];
return signa;
}
-(void)loadCatagoryData:(void(^)(id data))success{
success(@"123");
}
-(void)loadCatagoryDetail:(void(^)(id data))success{
success(@"456");
}
5:merge
可以调整两个信号的执行顺序 block 执行两边
-(void)merge{
RACSubject *signalA = [RACSubject subject];
RACSubject *signalB = [RACSubject subject];
[[signalA merge:signalB] subscribeNext:^(id _Nullable x) {
NSLog(@"%@",x);
}];
[signalA sendNext:@"A"];
[signalB sendNext:@"B"];
}
6：zip
-(void)zip{
RACSubject *signalA = [RACSubject subject];
RACSubject *signalB = [RACSubject subject];
[[signalA zipWith:signalB] subscribeNext:^(id _Nullable x) {
//把数据合并到一起 同事传输数据 数据是元祖的方式
//发送信号数量 必须大于1
RACTupleUnpack(NSString *A , NSString *B) = x;
NSLog(@"x === %@ A === %@ B === %@",x,A,B);
}];
[signalA sendNext:@"A"];
[signalB sendNext:@"B"];
}
7：Bind
loginButton 登录按钮
userNameTF 用户名的输入框
passWordTF 密码的输入框
绑定按钮的 点击状态 （如果 userNameTF passWordTF 有值loginButton.enable = YES (同理 NO) ）
RAC(self.loginButton,enabled) = [RACSignal combineLatest:@[self.userNameTF.rac_textSignal,self.passWordTF.rac_textSignal] reduce:^id(NSString *userName,NSString *password){
return @(userName.length && password.length);
}];
8:replay
作用：重复执行
项目实战：如果 token 请求失败 需要接着请求几次，但是不能一直请求 会设置最大请求次数 这个就能解决
-(void)replay{
__block NSInteger index = 1;
[[[RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber> _Nonnull subscriber) {
if (index == 5) {
[subscriber sendNext:@"重复"];
}else{
NSError *error = [NSError errorWithDomain:NSDocumentTypeDocumentOption code:-8080 userInfo:@{@"error":@"错误"}];
[subscriber sendError:error];
}
index++;
return nil;
}] retry] subscribeNext:^(id _Nullable x) {
NSLog(@"成功 --- %@",x);
}];
}
9：filter
过滤操作
-(void)filter{
[[self.passWord.rac_textSignal filter:^BOOL(NSString * _Nullable value) {
return value.length > 6;
}] subscribeNext:^(NSString * _Nullable x) {
NSLog(@"%@",x);
}];
}
