ReactiveCocoa简单介绍

// 1.创建信号 createSignal:didSubscribe(block)
// RACDisposable:取消订阅
// RACSubscriber:发送数据
RACSignal *siganl = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
   
   // block调用时刻:每当有订阅者订阅信号，就会调用block。
   // block作用:描述当前信号哪些数据需要发送
   // _subscriber = subscriber;

   // 3.发送信号
   NSLog(@"调用了didSubscribe");
   // 通常：传递数据出去
   [subscriber sendNext:@1];
   // 此处调用订阅者的nextBlock
   
   // 5.如果不再发送数据，最好发送信号完成，内部会自动调用[RACDisposable disposable]取消订阅信号。或者信号想要被取消，就必须返回一个RACDisposable，然后在后面[disposable dispose]
   [subscriber sendCompleted];
   
   return [RACDisposable disposableWithBlock:^{
       // 6.信号什么时候被取消：1.自动取消，当一个信号的订阅者被销毁的时候，就会自动取消订阅 2.主动取消
       // block调用时刻:一旦一个信号，被取消订阅的时候就会调用
       // block作用：当信号取消订阅，用于清空一些资源
       NSLog(@"取消订阅");
   }];
}];
    
// subscribeNext:创建订阅者，然后把nextBlock保存到订阅者里面
// 2.订阅信号：只要订阅信号，就会返回一个取消订阅信号的类
[siganl subscribeNext:^(id x) {
   // 4.block调用时刻：每当有信号发出数据，就会调用block。
   NSLog(@"接收到数据:%@",x);
}];
    
// 5.取消订阅
//    [disposable dispose];

// RACSubject:信号提供者
    
// 1.创建信号
RACSubject *subject = [RACSubject subject];
    
// 2.订阅信号
[subject subscribeNext:^(id x) {
   
   // 4.block:当有数据发出的时候就会调用
   // block:处理数据
   NSLog(@"第一个订阅者%@",x);
}];
    
// 发送信号
//    [subject sendNext:@1];
    
// 2.1 第二次订阅信号
[subject subscribeNext:^(id x) {
   // block调用时刻：当信号发出新值，就会调用.
   NSLog(@"第二个订阅者%@",x);
}];
    
// 3.发送信号
[subject sendNext:@1];
[subject sendNext:@2];

//在SubjectSecondViewController.h中添加一个RACSubject代替代理。
@property (nonatomic, strong) RACSubject *subject;

//监听SubjectSecondViewController的按钮点击
- (IBAction)backDidClick:(UIButton *)sender {
    
    // 4.点击返回按钮时，便可以通知SubjectViewController做事情
    if (self.subject) {
        
        [self.subject sendNext:@1];
    }
}

// 在SubjectViewController中，监听跳转按钮，给SubjectSecondViewController的代理信号赋值，并且监听
- (IBAction)buttonDidClick:(UIButton *)button {
    
    UIStoryboard *storyboard = [UIStoryboard storyboardWithName:@"Main" bundle:nil];
    
    SubjectSecondViewController *twoVc = [storyboard instantiateViewControllerWithIdentifier:@"two"];
    
    //1.创建并设置信号提供者
    twoVc.subject = [RACSubject subject];
    
    // 2.订阅信号
    @weakify(twoVc)
    [twoVc.subject subscribeNext:^(id x) {
        
        NSLog(@"通知了ViewController:%@", x);
        @strongify(twoVc)
        [twoVc dismissViewControllerAnimated:YES completion:^{
            
        }];
    }];
    
    // 3.present控制器
    [self presentViewController:twoVc animated:YES completion:nil];
    
}

// 1.创建信号
RACReplaySubject *subject = [RACReplaySubject subject];
    
// 2.订阅信号
[subject subscribeNext:^(id x) {
   
   NSLog(@"第一个订阅者%@",x);
}];
    
// 3.发送信号
[subject sendNext:@1];
    
[subject sendNext:@2];
    
[subject subscribeNext:^(id x) {
   
   NSLog(@"第二个订阅者%@",x);
}];

// 遍历字典,遍历出来的键值对会包装成RACTuple(元组对象)
NSDictionary *dict = @{@"name":@"Tony", @"age":@18};
[dict.rac_sequence.signal subscribeNext:^(RACTuple *x) {
   // 解包元组，会把元组的值，按顺序给参数里面的变量赋值
   RACTupleUnpack(NSString *key, NSString *value) = x;
   // 相当于以下写法
   // NSString *key = x[0];
   // NSString *value = x[1]; 
   NSLog(@"%@ %@", key, value);
}];

// 遍历数组
NSArray *arr = @[@1,@2,@3];
    
// 这里其实是三步
    
// 第一步: 把数组转换成集合RACSequence arr.rac_sequence
// 第二步: 把集合RACSequence转换RACSignal信号类，arr.rac_sequence.signal
// 第三步: 订阅信号，激活信号，会自动把集合中的所有值，遍历出来。
[arr.rac_sequence.signal subscribeNext:^(id x) {
   NSLog(@"%@",x);
}];

NSString *filePath = [[NSBundle mainBundle] pathForResource:@"flags.plist" ofType:nil];
NSArray *dictArr = [NSArray arrayWithContentsOfFile:filePath];

//OC
NSMutableArray *items = [NSMutableArray array];
for (NSDictionary *dict in dictArr) {
   FlagItem *item = [FlagItem flagWithDict:dict];
   [items addObject:item];
}
    
//RAC
NSMutableArray *flags = [NSMutableArray array];
// rac_sequence注意点：调用subscribeNext，并不会马上执行nextBlock，而是会等一会。
[dictArr.rac_sequence.signal subscribeNext:^(id x) {
   // 运用RAC遍历字典，x：字典
   FlagItem *item = [FlagItem flagWithDict:x];
   [flags addObject:item];
}];
    
// 使用map
// map:映射的意思，目的：把原始值value映射成一个新值
// array: 把集合转换成数组
// 底层实现：当信号被订阅，会遍历集合中的原始值，映射成新值，并且保存到新的数组里。
NSArray *newFlags = [[dictArr.rac_sequence map:^id(id value) {
   return [FlagItem flagWithDict:value];
}] array];
    
NSLog(@"%@, %@, %@", items, flags, newFlags);

// 创建命令类
RACCommand *command = [[RACCommand alloc] initWithSignalBlock:^RACSignal *(id input) {
   
   // block什么时候调用:当执行这个命令类的时候就会调用
   NSLog(@"执行命令 %@", input);
   // block有什么作用:描述下如何处理事件，网络请求
   
   // 创建空信号，必须返回信号
   // return [RACSignal empty];
   
   // 2.RACCommand必须返回信号，处理事件的时候，肯定会有数据产生，产生的数据就通过返回的信号发出。注意：数据传递完，最好调用sendCompleted，这时命令才执行完毕。
   return [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
       // block作用：发送处理事件的信号
       // block调用：当信号被订阅的时候才会调用
       [subscriber sendNext:@"信号发出的内容"];
       [subscriber sendCompleted];
       
       return nil;
   }];
}];
    
// 强引用命令，不要被销毁，否则接收不到数据
_command = command;
// executionSignals:信号源，包含事件处理的所有信号。
// executionSignals: signalOfSignals，信号中的信号，就是信号发出的数据也是信号类
    
// 3.如果想要订阅接收信号源的信号内容，必须保证命令类不会被销毁
[command.executionSignals subscribeNext:^(id x) {
   // x -> 信号
   [x subscribeNext:^(id x) {
       
       NSLog(@"%@",x);
   }];
}]; 
// 4.执行命令,调用signalBlock
[command execute:@1];
     
// RAC高级用法
// switchToLatest:用于signal of signals，获取signal of signals发出的最新信号,也就是可以直接拿到RACCommand中的信号
[command.executionSignals.switchToLatest subscribeNext:^(id x) {
   NSLog(@"%@",x);
}];
    
// 5.监听命令是否执行完毕，默认会来一次，可以直接跳过，skip表示跳过第一次信号。
[[command.executing skip:1] subscribeNext:^(id x) {
   if ([x boolValue] == YES) {
       // 正在执行
       NSLog(@"正在执行");
       
   }else{
       // 执行完成
       NSLog(@"执行完成");
   }
}];

// 发送请求，用一个信号内包装，不管有多少个订阅者，只想要发送一次请求
RACSignal *signal = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
   // didSubscribe（block）中的代码都统称为副作用（Side Effects）。
   // 发送请求
   NSLog(@"发送请求");
   [subscriber sendNext:@1];
   return nil;
}]; 
// 订阅信号
[signal subscribeNext:^(id x) {
   NSLog(@"接收数据：%@",x);
}];
[signal subscribeNext:^(id x) {
   NSLog(@"接收数据：%@",x);
}];

// RACMulticastConnection:解决重复请求问题
// 1.创建信号
RACSignal *signal = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
   NSLog(@"发送请求");
   [subscriber sendNext:@1];
   return nil;
}];
// 2.创建连接
RACMulticastConnection *connect = [signal publish];
// 3.订阅信号，
// 注意：订阅信号，也不能激活信号，只是保存订阅者到数组，必须通过连接,当调用连接，就会一次性调用所有订阅者的sendNext:
[connect.signal subscribeNext:^(id x) {
   NSLog(@"订阅者一信号");
}];
[connect.signal subscribeNext:^(id x) {
   NSLog(@"订阅者二信号");
}];
// 4.连接,激活信号
[connect connect];