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
