ReactiveCocoa(FRP)-进阶篇（上）

- 运用的是Hook（钩子）思想，Hook是一种用于改变API(应用程序编程接口：方法)执行结果的技术.
- Hook用处：截获API调用的技术。
- Hook原理：在每次调用一个API返回结果之前，先执行你自己的方法，改变结果的输出。
- RAC开发方式：RAC中核心开发方式，也是**绑定**，之前的开发方式是赋值，而用RAC开发，应该把重心放在绑定，也就是可以在创建一个对象的时候，就绑定好以后想要做的事情，而不是等赋值之后在去做事情。
- 列如：把数据展示到控件上，之前都是重写控件的setModel方法，用RAC就可以在一开始创建控件的时候，就绑定好数据。

NSLog(@"输出:%@",x);
  }];

bind方法参数:需要传入一个返回值是RACStreamBindBlock的block参数
 RACStreamBindBlock是一个block的类型，返回值是信号，参数（value,stop），因此参数的block返回值也是一个block。
RACStreamBindBlock:
参数一(value):表示接收到信号的原始值，还没做处理
参数二(*stop):用来控制绑定Block，如果*stop = yes,那么就会结束绑定。
返回值：信号，做好处理，在通过这个信号返回出去，一般使用RACReturnSignal,需要手动导入头文件RACReturnSignal.h。

[[_textField.rac_textSignal bind:^RACStreamBindBlock{
// 什么时候调用:
// block作用:表示绑定了一个信号.
return ^RACStream *(id value, BOOL *stop){
    // 什么时候调用block:当信号有新的值发出，就会来到这个block。
    // block作用:做返回值的处理
    // 做好处理，通过信号返回出去.
    return [RACReturnSignal return:[NSString stringWithFormat:@"输出:%@",value]];
};
}] subscribeNext:^(id x) {
      NSLog(@"%@",x);
}];

//1.创建信号
  RACSubject *subject =[RACSubject subject];
//2.绑定信号
  [[subject flattenMap:^RACStream *(id value) {
// block 只要原信号发送内容就会调用
// value 就是源信号发送的内容
   NSLog(@"11---%@",[NSThread currentThread]);
   value = [NSString stringWithFormat:@"JK %@",value];
 // 返回信号用来包装成修改内容的值
     return [RACReturnSignal return:value];
 }] subscribeNext:^(id x) {
 //3.订阅信号,flattenMap中返回的是什么信号,订阅的就是什么信号
   NSLog(@"%@",x);
    NSLog(@"22---%@",[NSThread currentThread]);
 }];
 //4.源信号发送信号
 [subject sendNext:@"123"];

//1.创建信号
    RACSubject *subject =[RACSubject subject];
//2.绑定信号
    [[subject map:^id(id value) {
// 返回的内容就是你要映射的值
   value = [NSString stringWithFormat:@"JK:%@",value];
   return value;
   }]subscribeNext:^(id x) {
      NSLog(@"映射之后的值= %@",x);
   }];
 //4.源信号发送信号
 [subject sendNext:@"123"];

// 创建信号中的信号
 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];

// 1.创建信号中的信号
RACSubject *signalOfsignals = [RACSubject subject];
RACSubject *signal = [RACSubject subject];
//2.创建订阅者的种方式
   //第1种方式
[signalOfsignals.switchToLatest subscribeNext:^(id x) {
    NSLog(@"%@",x);
}];
// 第2种方式
[signalOfsignals subscribeNext:^(RACSignal *x) {
    [x subscribeNext:^(id x) {
        NSLog(@"%@",x);
    }];
}];
 // 第3种方式
[[signalOfsignals flattenMap:^RACStream *(id value) {
    // 当signalOfsignals的signals发出信号才会调用
    return value;
}] subscribeNext:^(id x) {
    // 只有signalOfsignals的signal发出信号才会调用，因为内部订阅了bindBlock中返回的信号，也就是flattenMap返回的信号。
    // 也就是flattenMap返回的信号发出内容，才会调用。
    //5.打印信号发送的内容(可以进行修改)
    NSLog(@"%@aaa",x);
}];
// 3.信号的信号发送信号
[signalOfsignals sendNext:signal];
// 4.信号发送内容
[signal sendNext:@1];

RACSignal *signalA = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
[subscriber sendNext:@1];
[subscriber sendCompleted];
   return nil;
}];
RACSignal *signalB = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
   [subscriber sendNext:@2];
   return nil;
}];
// 把signalA拼接到signalB后，signalA发送完成，signalB才会被激活。
RACSignal *concatSignal = [signalA concat:signalB];
// 以后只需要面对拼接信号开发。
// 订阅拼接的信号，不需要单独订阅signalA，signalB
// 内部会自动订阅。
// 注意：第一个信号必须发送完成，第二个信号才会被激活
[concatSignal subscribeNext:^(id 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中发送值,就会通过拼接信号的订阅者把值发送出来.

[subscriber sendNext:@1];
    [subscriber sendCompleted];
   return nil;
 }] then:^RACSignal *{
     return [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
  [subscriber sendNext:@2];
  return nil;
   }];
 }] subscribeNext:^(id x) {
   // 只能接收到第二个信号的值，也就是then返回信号的值
   NSLog(@"%@",x);
}];