最快让你上手ReactiveCocoa之进阶篇

 1     RACSignal *signalA = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
 2 
 3         [subscriber sendNext:@1];
 4 
 5         [subscriber sendCompleted];
 6 
 7         return nil;
 8     }];
 9     RACSignal *signalB = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
10 
11         [subscriber sendNext:@2];
12 
13         return nil;
14     }];
15 
16     // 把signalA拼接到signalB后，signalA发送完成，signalB才会被激活。
17     RACSignal *concatSignal = [signalA concat:signalB];
18 
19     // 以后只需要面对拼接信号开发。
20     // 订阅拼接的信号，不需要单独订阅signalA，signalB
21     // 内部会自动订阅。
22     // 注意：第一个信号必须发送完成，第二个信号才会被激活
23     [concatSignal subscribeNext:^(id x) {
24 
25         NSLog(@"%@",x);
26 
27     }];
28 
29     // concat底层实现:
30     // 1.当拼接信号被订阅，就会调用拼接信号的didSubscribe
31     // 2.didSubscribe中，会先订阅第一个源信号（signalA）
32     // 3.会执行第一个源信号（signalA）的didSubscribe
33     // 4.第一个源信号（signalA）didSubscribe中发送值，就会调用第一个源信号（signalA）订阅者的nextBlock,通过拼接信号的订阅者把值发送出来.
34     // 5.第一个源信号（signalA）didSubscribe中发送完成，就会调用第一个源信号（signalA）订阅者的completedBlock,订阅第二个源信号（signalB）这时候才激活（signalB）。
35     // 6.订阅第二个源信号（signalB）,执行第二个源信号（signalB）的didSubscribe
36     // 7.第二个源信号（signalA）didSubscribe中发送值,就会通过拼接信号的订阅者把值发送出来.

 1 // then:用于连接两个信号，当第一个信号完成，才会连接then返回的信号
 2 // 注意使用then，之前信号的值会被忽略掉.
 3 // 底层实现：1、先过滤掉之前的信号发出的值。2.使用concat连接then返回的信号
 4 [[[RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
 5 
 6  [subscriber sendNext:@1];
 7  [subscriber sendCompleted];
 8  return nil;
 9 }] then:^RACSignal *{
10  return [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
11      [subscriber sendNext:@2];
12      return nil;
13  }];
14 }] subscribeNext:^(id x) {
15 
16  // 只能接收到第二个信号的值，也就是then返回信号的值
17  NSLog(@"%@",x);
18 }];

 1     // merge:把多个信号合并成一个信号
 2     //创建多个信号
 3     RACSignal *signalA = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
 4 
 5         [subscriber sendNext:@1];
 6 
 7 
 8         return nil;
 9     }];
10 
11     RACSignal *signalB = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
12 
13         [subscriber sendNext:@2];
14 
15         return nil;
16     }];
17 
18     // 合并信号,任何一个信号发送数据，都能监听到.
19     RACSignal *mergeSignal = [signalA merge:signalB];
20 
21     [mergeSignal subscribeNext:^(id x) {
22 
23         NSLog(@"%@",x);
24 
25     }];
26 
27     // 底层实现：
28     // 1.合并信号被订阅的时候，就会遍历所有信号，并且发出这些信号。
29     // 2.每发出一个信号，这个信号就会被订阅
30     // 3.也就是合并信号一被订阅，就会订阅里面所有的信号。
31     // 4.只要有一个信号被发出就会被监听。

 1  RACSignal *signalA = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
 2 
 3         [subscriber sendNext:@1];
 4 
 5 
 6         return nil;
 7     }];
 8 
 9     RACSignal *signalB = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
10 
11         [subscriber sendNext:@2];
12 
13         return nil;
14     }];
15 
16 
17 
18     // 压缩信号A，信号B
19     RACSignal *zipSignal = [signalA zipWith:signalB];
20 
21     [zipSignal subscribeNext:^(id x) {
22 
23         NSLog(@"%@",x);
24     }];
25 
26     // 底层实现:
27     // 1.定义压缩信号，内部就会自动订阅signalA，signalB
28     // 2.每当signalA或者signalB发出信号，就会判断signalA，signalB有没有发出个信号，有就会把最近

 1  RACSignal *signalA = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
 2 
 3    [subscriber sendNext:@1];
 4 
 5    return nil;
 6 }];
 7 
 8 RACSignal *signalB = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
 9 
10    [subscriber sendNext:@2];
11 
12    return nil;
13 }];
14 
15 // 把两个信号组合成一个信号,跟zip一样，没什么区别
16 RACSignal *combineSignal = [signalA combineLatestWith:signalB];
17 
18 [combineSignal subscribeNext:^(id x) {
19 
20    NSLog(@"%@",x);
21 }];
22 
23 // 底层实现：
24 // 1.当组合信号被订阅，内部会自动订阅signalA，signalB,必须两个信号都发出内容，才会被触发。
25 // 2.并且把两个信号组合成元组发出。

 1 RACSignal *signalA = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
 2 
 3    [subscriber sendNext:@1];
 4 
 5    return nil;
 6 }];
 7 
 8 RACSignal *signalB = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
 9 
10    [subscriber sendNext:@2];
11 
12    return nil;
13 }];
14 
15 // 聚合
16 // 常见的用法，（先组合在聚合）。combineLatest:(id<NSFastEnumeration>)signals reduce:(id (^)())reduceBlock
17 // reduce中的block简介:
18 // reduceblcok中的参数，有多少信号组合，reduceblcok就有多少参数，每个参数就是之前信号发出的内容
19 // reduceblcok的返回值：聚合信号之后的内容。
20 RACSignal *reduceSignal = [RACSignal combineLatest:@[signalA,signalB] reduce:^id(NSNumber *num1 ,NSNumber *num2){
21 
22   return [NSString stringWithFormat:@"%@ %@",num1,num2];
23 
24 }];
25 
26 [reduceSignal subscribeNext:^(id x) {
27 
28    NSLog(@"%@",x);
29 }];
30 
31 // 底层实现:
32 // 1.订阅聚合信号，每次有内容发出，就会执行reduceblcok，把信号内容转换成reduceblcok返回的值。

1 // 过滤:
2 // 每次信号发出，会先执行过滤条件判断.
3 [_textField.rac_textSignal filter:^BOOL(NSString *value) {
4        return value.length > 3;
5 }];

1    // 内部调用filter过滤，忽略掉ignore的值
2 [[_textField.rac_textSignal ignore:@"1"] subscribeNext:^(id x) {
3 
4    NSLog(@"%@",x);
5 }];

1    // 过滤，当上一次和当前的值不一样，就会发出内容。
2 // 在开发中，刷新UI经常使用，只有两次数据不一样才需要刷新
3 [[_textField.rac_textSignal distinctUntilChanged] subscribeNext:^(id x) {
4 
5    NSLog(@"%@",x);
6 }];

 1 // 1、创建信号
 2 RACSubject *signal = [RACSubject subject];
 3 
 4 // 2、处理信号，订阅信号
 5 [[signal take:1] subscribeNext:^(id x) {
 6 
 7    NSLog(@"%@",x);
 8 }];
 9 
10 // 3.发送信号
11 [signal sendNext:@1];
12 
13 [signal sendNext:@2];
14 
15 

 1 // 1、创建信号
 2 RACSubject *signal = [RACSubject subject];
 3 
 4 // 2、处理信号，订阅信号
 5 [[signal takeLast:1] subscribeNext:^(id x) {
 6 
 7    NSLog(@"%@",x);
 8 }];
 9 
10 // 3.发送信号
11 [signal sendNext:@1];
12 
13 [signal sendNext:@2];
14 
15 [signal sendCompleted];

1 // 表示输入第一次，不会被监听到，跳过第一次发出的信号
2 [[_textField.rac_textSignal skip:1] subscribeNext:^(id x) {
3 
4    NSLog(@"%@",x);
5 }];

 1 RACSubject *signalOfSignals = [RACSubject subject];
 2 RACSubject *signal = [RACSubject subject];
 3 
 4 // 获取信号中信号最近发出信号，订阅最近发出的信号。
 5 // 注意switchToLatest：只能用于信号中的信号
 6 [signalOfSignals.switchToLatest subscribeNext:^(id x) {
 7 
 8    NSLog(@"%@",x);
 9 }];
10 [signalOfSignals sendNext:signal];
11 [signal sendNext:@1];
12 

 1 [[[[RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
 2   [subscriber sendNext:@1];
 3   [subscriber sendCompleted];
 4   return nil;
 5 }] doNext:^(id x) {
 6 // 执行[subscriber sendNext:@1];之前会调用这个Block
 7   NSLog(@"doNext");;
 8 }] doCompleted:^{
 9    // 执行[subscriber sendCompleted];之前会调用这个Block
10   NSLog(@"doCompleted");;
11 
12 }] subscribeNext:^(id x) {
13 
14   NSLog(@"%@",x);
15 }];
16 

 1 RACSignal *signal = [[RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
 2  return nil;
 3 }] timeout:1 onScheduler:[RACScheduler currentScheduler]];
 4 
 5 [signal subscribeNext:^(id x) {
 6 
 7  NSLog(@"%@",x);
 8 } error:^(NSError *error) {
 9  // 1秒后会自动调用
10  NSLog(@"%@",error);
11 }];

1 [[RACSignal interval:1 onScheduler:[RACScheduler currentScheduler]] subscribeNext:^(id x) {
2 
3  NSLog(@"%@",x);
4 }];

 1  RACSignal *signal = [[[RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
 2 
 3  [subscriber sendNext:@1];
 4  return nil;
 5 }] delay:2] subscribeNext:^(id x) {
 6 
 7  NSLog(@"%@",x);
 8 }];
 9 

 1      __block int i = 0;
 2     [[[RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
 3 
 4             if (i == 10) {
 5                 [subscriber sendNext:@1];
 6             }else{
 7                 NSLog(@"接收到错误");
 8                 [subscriber sendError:nil];
 9             }
10             i++;
11 
12         return nil;
13 
14     }] retry] subscribeNext:^(id x) {
15 
16         NSLog(@"%@",x);
17 
18     } error:^(NSError *error) {
19 
20 
21     }];
22 

 1         RACSignal *signal = [[RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
 2 
 3 
 4         [subscriber sendNext:@1];
 5         [subscriber sendNext:@2];
 6 
 7         return nil;
 8     }] replay];
 9 
10     [signal subscribeNext:^(id x) {
11 
12         NSLog(@"第一个订阅者%@",x);
13 
14     }];
15 
16     [signal subscribeNext:^(id x) {
17 
18         NSLog(@"第二个订阅者%@",x);
19 
20     }];
21 

 1    RACSubject *signal = [RACSubject subject];
 2 
 3 _signal = signal;
 4 
 5 // 节流，在一定时间（1秒）内，不接收任何信号内容，过了这个时间（1秒）获取最后发送的信号内容发出。
 6 [[signal throttle:1] subscribeNext:^(id x) {
 7 
 8    NSLog(@"%@",x);
 9 }];
10 
11