ReactiveCocoa操作方法過濾

filter：過濾信號(hào)，可以使用它獲取滿足調(diào)價(jià)的信號(hào)
//每次信號(hào)發(fā)出都會(huì)先執(zhí)行過濾條件判斷
[[self.textfield1.rac_textSignal filter:^BOOL(NSString *value) {
// 當(dāng)條件判斷等于YES的時(shí)候才會(huì)調(diào)用訂閱的block
return value.length>5;
}] subscribeNext:^(id x) {
self.loginBtn.enabled = YES;
} ];
ignore:忽略完某些值的信號(hào)
// 內(nèi)部調(diào)用filter過濾，忽略掉ignore的值
[[self.textfield1.rac_textSignal ignore:@"123"] subscribeNext:^(id x) {
NSLog(@"%@",x);
}];

distinctUntilChanged:當(dāng)上一次的值和這次的值有明顯變化的時(shí)候就會(huì)發(fā)出信號(hào)，否則會(huì)忽略掉
RACSubject *subject = [RACSubject subject];
//當(dāng)上一次的值和這次的值有明顯變化的時(shí)候就會(huì)發(fā)出信號(hào)，否則會(huì)忽略掉
//一般用來刷新UI界面，當(dāng)數(shù)據(jù)有變化的時(shí)候才會(huì)刷新
[[subject distinctUntilChanged] subscribeNext:^(id x) {
NSLog(@"%@",x);
}];

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

take：從開始一共取N次的信號(hào)
RACSubject *subject = [RACSubject subject];
//只取前兩次的信號(hào)
[[subject take:2] subscribeNext:^(id x) {
NSLog(@"%@",x);
}];

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

takeLast:取最后N次的信號(hào)，前提條件訂閱者必須調(diào)用完成，因?yàn)橹挥型瓿刹胖酪还灿卸嗌傩盘?hào)

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

[subject sendNext:@"123456"];
[subject sendNext:@"12346"];
[subject sendNext:@"last1"];
[subject sendNext:@"last2"];
[subject sendCompleted];//訂閱者必須調(diào)用完成
//輸出
/*
2016-05-18 15:04:36.700 ReactiveCocoaTest1[3220:219323] last1
2016-05-18 15:04:36.701 ReactiveCocoaTest1[3220:219323] last2

*/

skip:(NSUInteger):跳過幾個(gè)信號(hào),不接受
//感覺這個(gè)地方有bug,當(dāng)文本框獲取到焦點(diǎn)的時(shí)候就調(diào)用了
//因?yàn)槌绦騿?dòng)初始化這個(gè)空間的時(shí)候會(huì)調(diào)用第一次
// 輸入第一次不會(huì)被監(jiān)聽到，跳過第一次發(fā)出的信號(hào)
[[self.textfield1.rac_textSignal skip:1] subscribeNext:^(id x) {
NSLog(@"%@",x);
}];

ReactiveCocoa操作方法之秩序
doNext: 執(zhí)行Next之前，會(huì)先執(zhí)行這個(gè)Block
doCompleted：: 執(zhí)行sendCompleted之前，會(huì)先執(zhí)行這個(gè)Block

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

    [subscriber sendCompleted];
    NSLog(@"發(fā)送完畢");
    return nil;
}] doNext:^(id x) {
    // 執(zhí)行[subscriber sendNext:@100];之前會(huì)調(diào)用這個(gè)Block
     NSLog(@"doNext%@",x);
}] doCompleted:^{
    //執(zhí)行[subscriber sendCompleted];之前調(diào)用這個(gè)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] 發(fā)送完畢
 */

ReactiveCocoa操作方法之時(shí)間
timeout：超時(shí)，可以讓一個(gè)信號(hào)在一定的時(shí)間后，自動(dòng)報(bào)錯(cuò)。
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秒后會(huì)自動(dòng)調(diào)用");
}];

interval:定時(shí)，每隔一段時(shí)間發(fā)出信號(hào)
//每隔一秒鐘就會(huì)發(fā)出信號(hào)
[[RACSignal interval:1 onScheduler:[RACScheduler currentScheduler]] subscribeNext:^(id x) {
NSLog(@"%@",x);
}];

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

    return nil;
}] delay:2] subscribeNext:^(id x) {
    //調(diào)用[subscriber sendNext:@"100"] 2秒之后執(zhí)行這個(gè)block
    NSLog(@"%@",x);
}];

ReactiveCocoa操作方法之重復(fù)
retry:重試，只要失敗，就會(huì)重新執(zhí)行創(chuàng)建信號(hào)中的block,直到成功

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

    if (i == 10) {
        [subscriber sendNext:@1];
    }else{
        NSLog(@"接收到錯(cuò)誤");
        [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] 接收到錯(cuò)誤
 2016-05-18 17:07:27.522 ReactiveCocoaTest1[5695:293689] 接收到錯(cuò)誤
 2016-05-18 17:07:27.523 ReactiveCocoaTest1[5695:293689] 接收到錯(cuò)誤
 2016-05-18 17:07:27.523 ReactiveCocoaTest1[5695:293689] 接收到錯(cuò)誤
 2016-05-18 17:07:27.523 ReactiveCocoaTest1[5695:293689] 接收到錯(cuò)誤
 2016-05-18 17:07:27.524 ReactiveCocoaTest1[5695:293689] 接收到錯(cuò)誤
 2016-05-18 17:07:27.524 ReactiveCocoaTest1[5695:293689] 接收到錯(cuò)誤
 2016-05-18 17:07:27.525 ReactiveCocoaTest1[5695:293689] 接收到錯(cuò)誤
 2016-05-18 17:07:27.525 ReactiveCocoaTest1[5695:293689] 接收到錯(cuò)誤
 2016-05-18 17:07:27.525 ReactiveCocoaTest1[5695:293689] 接收到錯(cuò)誤
 2016-05-18 17:07:27.525 ReactiveCocoaTest1[5695:293689] 1
 */

replay重放，當(dāng)一個(gè)信號(hào)被訂閱多次，反復(fù)播放內(nèi)容
//replay重放：當(dāng)一個(gè)信號(hào)被多次訂閱,反復(fù)播放內(nèi)容
//沒有明白這個(gè)有何意義
RACSignal *signal = [[RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {

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

[signal subscribeNext:^(id x) {
    
    NSLog(@"第一個(gè)訂閱者%@",x);
    
}];

[signal subscribeNext:^(id x) {
    
    NSLog(@"第二個(gè)訂閱者%@",x);
    
}];

throttle節(jié)流 ：當(dāng)某個(gè)信號(hào)發(fā)送比較頻繁時(shí)，可以使用節(jié)流，在某一段時(shí)間不發(fā)送信號(hào)內(nèi)容，過了一段時(shí)間獲取信號(hào)的最新內(nèi)容發(fā)出。

 RACSubject *signal = [RACSubject subject];

_signal = signal;

// 節(jié)流，在一定時(shí)間（1秒）內(nèi)，不接收任何信號(hào)內(nèi)容，過了這個(gè)時(shí)間（1秒）獲取最后發(fā)送的信號(hào)內(nèi)容發(fā)出。
[[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

不正確之處，歡迎補(bǔ)充
測(cè)試代碼 https://github.com/CharType/ReactiveCocoaTest