ReactiveCocoa操作方法(过滤，秩序,时间，重复)

ReactiveCocoa操作方法过滤

filter：过滤信号，可以使用它获取满足调价的信号
//每次信号发出都会先执行过滤条件判断
[[self.textfield1.rac_textSignal filter:^BOOL(NSString *value) {
// 当条件判断等于YES的时候才会调用订阅的block
return value.length>5;
}] subscribeNext:^(id x) {
self.loginBtn.enabled = YES;
} ];
ignore:忽略完某些值的信号
// 内部调用filter过滤，忽略掉ignore的值
[[self.textfield1.rac_textSignal ignore:@"123"] subscribeNext:^(id x) {
NSLog(@"%@",x);
}];

distinctUntilChanged:当上一次的值和这次的值有明显变化的时候就会发出信号，否则会忽略掉
RACSubject *subject = [RACSubject subject];
//当上一次的值和这次的值有明显变化的时候就会发出信号，否则会忽略掉
//一般用来刷新UI界面，当数据有变化的时候才会刷新
[[subject distinctUntilChanged] subscribeNext:^(id x) {
NSLog(@"%@",x);
}];

[subject sendNext:@"123456"];
[subject sendNext:@"12346”];

take：从开始一共取N次的信号
RACSubject *subject = [RACSubject subject];
//只取前两次的信号
[[subject take:2] subscribeNext:^(id x) {
NSLog(@"%@",x);
}];

[subject sendNext:@"123456"];
[subject sendNext:@"12346"];
[subject sendNext:@"123456"];
[subject sendNext:@"12346”];

takeLast:取最后N次的信号，前提条件订阅者必须调用完成，因为只有完成才知道一共有多少信号

RACSubject *subject = [RACSubject subject];
//只取最后两次的信号
[[subject takeLast:2] subscribeNext:^(id x) {
NSLog(@"%@",x);
}];

[subject sendNext:@"123456"];
[subject sendNext:@"12346"];
[subject sendNext:@"last1"];
[subject sendNext:@"last2"];
[subject sendCompleted];//订阅者必须调用完成
//输出
/*
2016-05-18 15:04:36.700 ReactiveCocoaTest1[3220:219323] last1
2016-05-18 15:04:36.701 ReactiveCocoaTest1[3220:219323] last2

*/

skip:(NSUInteger):跳过几个信号,不接受
//感觉这个地方有bug,当文本框获取到焦点的时候就调用了
//因为程序启动初始化这个空间的时候会调用第一次
// 输入第一次不会被监听到，跳过第一次发出的信号
[[self.textfield1.rac_textSignal skip:1] subscribeNext:^(id x) {
NSLog(@"%@",x);
}];

ReactiveCocoa操作方法之秩序
doNext: 执行Next之前，会先执行这个Block
doCompleted：: 执行sendCompleted之前，会先执行这个Block

RACSignal *signal = [[[RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
[subscriber sendNext:@"100"];

    [subscriber sendCompleted];
    NSLog(@"发送完毕");
    return nil;
}] doNext:^(id x) {
    // 执行[subscriber sendNext:@100];之前会调用这个Block
     NSLog(@"doNext%@",x);
}] doCompleted:^{
    //执行[subscriber sendCompleted];之前调用这个block
     NSLog(@"doCompleted");;
}];

[signal subscribeNext:^(id x) {
    NSLog(@"%@",x);
}];
/*
 输出：
 2016-05-18 15:42:53.720 ReactiveCocoaTest1[4966:252147] doNext100
 2016-05-18 15:42:53.720 ReactiveCocoaTest1[4966:252147] 100
 2016-05-18 15:42:53.720 ReactiveCocoaTest1[4966:252147] doCompleted
 2016-05-18 15:42:53.720 ReactiveCocoaTest1[4966:252147] 发送完毕
 */

ReactiveCocoa操作方法之时间
timeout：超时，可以让一个信号在一定的时间后，自动报错。
RACSignal *signal = [[RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
[subscriber sendNext:@"100"];
return nil;
}] timeout:1 onScheduler: [RACScheduler currentScheduler]];

[signal subscribeNext:^(id x) {
    NSLog(@"%@",x);
} error:^(NSError *error) {
    
    NSLog(@"1秒后会自动调用");
}];

interval:定时，每隔一段时间发出信号
//每隔一秒钟就会发出信号
[[RACSignal interval:1 onScheduler:[RACScheduler currentScheduler]] subscribeNext:^(id x) {
NSLog(@"%@",x);
}];

delay:延迟发送Next
[[[RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
[subscriber sendNext:@"100"];

    return nil;
}] delay:2] subscribeNext:^(id x) {
    //调用[subscriber sendNext:@"100"] 2秒之后执行这个block
    NSLog(@"%@",x);
}];

ReactiveCocoa操作方法之重复
retry:重试，只要失败，就会重新执行创建信号中的block,直到成功

__block int i = 0;
[[[RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {

    if (i == 10) {
        [subscriber sendNext:@1];
    }else{
        NSLog(@"接收到错误");
        [subscriber sendError:nil];
    }
    i++;
    
    return nil;
    
}] retry] subscribeNext:^(id x) {
    
    NSLog(@"%@",x);
    
} error:^(NSError *error) {
    
}];
/*
 输出：
 2016-05-18 17:07:27.494 ReactiveCocoaTest1[5695:293689] 接收到错误
 2016-05-18 17:07:27.522 ReactiveCocoaTest1[5695:293689] 接收到错误
 2016-05-18 17:07:27.523 ReactiveCocoaTest1[5695:293689] 接收到错误
 2016-05-18 17:07:27.523 ReactiveCocoaTest1[5695:293689] 接收到错误
 2016-05-18 17:07:27.523 ReactiveCocoaTest1[5695:293689] 接收到错误
 2016-05-18 17:07:27.524 ReactiveCocoaTest1[5695:293689] 接收到错误
 2016-05-18 17:07:27.524 ReactiveCocoaTest1[5695:293689] 接收到错误
 2016-05-18 17:07:27.525 ReactiveCocoaTest1[5695:293689] 接收到错误
 2016-05-18 17:07:27.525 ReactiveCocoaTest1[5695:293689] 接收到错误
 2016-05-18 17:07:27.525 ReactiveCocoaTest1[5695:293689] 接收到错误
 2016-05-18 17:07:27.525 ReactiveCocoaTest1[5695:293689] 1
 */

replay重放，当一个信号被订阅多次，反复播放内容
//replay重放：当一个信号被多次订阅,反复播放内容
//没有明白这个有何意义
RACSignal *signal = [[RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {

    [subscriber sendNext:@1];
    [subscriber sendNext:@2];
    
    return nil;
}] replay];

[signal subscribeNext:^(id x) {
    
    NSLog(@"第一个订阅者%@",x);
    
}];

[signal subscribeNext:^(id x) {
    
    NSLog(@"第二个订阅者%@",x);
    
}];

throttle节流 ：当某个信号发送比较频繁时，可以使用节流，在某一段时间不发送信号内容，过了一段时间获取信号的最新内容发出。

 RACSubject *signal = [RACSubject subject];

_signal = signal;

// 节流，在一定时间（1秒）内，不接收任何信号内容，过了这个时间（1秒）获取最后发送的信号内容发出。
[[signal throttle:1] subscribeNext:^(id x) {
    
    NSLog(@"%@",x);
}];

[signal sendNext:@"100"];
[signal sendNext:@"1000"];
//输出 2016-05-18 17:14:24.841 ReactiveCocoaTest1[6097:299606] 1000

不正确之处，欢迎补充
测试代码 https://github.com/CharType/ReactiveCocoaTest