最近一直在研究ReactiveCocoa西乖，現(xiàn)在也來講講ReactiveCocoa中一些基礎(chǔ)類的作用。

ReactiveCocoa作用

在我們iOS開發(fā)過程中典鸡，當(dāng)某些事件響應(yīng)的時(shí)候坏晦，需要處理某些業(yè)務(wù)邏輯,這些事件都用不同的方式來處理。比如按鈕的點(diǎn)擊使用action睁冬，ScrollView滾動(dòng)使用delegate看疙，屬性值改變使用KVO等系統(tǒng)提供的方式。其實(shí)這些事件施禾，都可以通過RAC處理搁胆。

RACSiganl

RACSiganl: 信號(hào)類,只是表示當(dāng)數(shù)據(jù)改變時(shí)邮绿，信號(hào)內(nèi)部會(huì)發(fā)出數(shù)據(jù)攀例，它本身不具備發(fā)送信號(hào)的能力，而是交給內(nèi)部一個(gè)訂閱者去發(fā)出傻唾。

RACSubscriber: 表示訂閱者的意思承耿，用于發(fā)送信號(hào)，這是一個(gè)協(xié)議加袋，不是一個(gè)類，只要遵守這個(gè)協(xié)議职烧，并且實(shí)現(xiàn)方法才能成為訂閱者。通過create創(chuàng)建的信號(hào)蝗敢，都有一個(gè)訂閱者足删，幫助他發(fā)送數(shù)據(jù)

RACDisposable: 用于取消訂閱或者清理資源，當(dāng)信號(hào)發(fā)送完成或者發(fā)送錯(cuò)誤的時(shí)候讶泰，就會(huì)自動(dòng)觸發(fā)它。

 //1.創(chuàng)建信號(hào)
    RACSignal *signal = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
        //block調(diào)用時(shí)刻：每當(dāng)有訂閱者訂閱信號(hào)痪署，就會(huì)調(diào)用block
        
        //2.發(fā)送信號(hào)
        [subscriber sendNext:@1];
        
        //如果不再發(fā)送數(shù)據(jù)狼犯，最好發(fā)送信號(hào)完成，內(nèi)部會(huì)自動(dòng)調(diào)用[RACDisposable disposable]取消訂閱
        [subscriber sendCompleted];
        
        return [RACDisposable disposableWithBlock:^{
            //block調(diào)用時(shí)刻：當(dāng)信號(hào)發(fā)送完成或者發(fā)送錯(cuò)誤悯森，就會(huì)自動(dòng)執(zhí)行這個(gè)block罐孝，取消訂閱
            NSLog(@"信號(hào)被銷毀");
        }];
    }];
    
    
    //3.訂閱信號(hào)
    [signal subscribeNext:^(id x) {
        //block調(diào)用時(shí)刻：每當(dāng)有信號(hào)發(fā)送數(shù)據(jù)，就會(huì)調(diào)用該方法
        NSLog(@"接收到的數(shù)據(jù)：%@",x);
    }];
    

RACSubject與RACReplaySubject

RACSubject:信號(hào)提供者汹来，自己可以充當(dāng)信號(hào)，又能發(fā)送信號(hào)改艇。subject可以想成是signal的變體，就像NSMutableArray相對(duì)于NSArray一樣摔桦。它們是非RAC的代碼和RAC代碼之間的橋梁承疲。

RACReplaySubject:重復(fù)提供信號(hào)類，RACSubject的子類兄世。

RACReplaySubject與RACSubject區(qū)別:

• RACReplaySubject可以先發(fā)送信號(hào)啊研，再訂閱信號(hào)，RACSubject就不可以削解。

• RACReplaySubject可以設(shè)置capacity數(shù)量來限制緩存的value的數(shù)量,即只緩充最新的幾個(gè)值沟娱。

• 如果一個(gè)信號(hào)每被訂閱一次，就需要把之前的值重復(fù)發(fā)送一遍柳爽，就需要使用RACReplaySubject

   //1.創(chuàng)建信號(hào)
    RACSubject *subject = [RACSubject subject];
    
    //2.訂閱信號(hào)
    [subject subscribeNext:^(id x) {
        //block調(diào)用時(shí)刻：當(dāng)信號(hào)發(fā)出新值碱屁，就會(huì)調(diào)用
        NSLog(@"第一個(gè)訂閱者%@",x);
    }];
    [subject subscribeNext:^(id x) {
        //block調(diào)用時(shí)刻：當(dāng)信號(hào)發(fā)出新值，就會(huì)調(diào)用
        NSLog(@"第二個(gè)訂閱者%@",x);
    }];
    
    //3.發(fā)送信號(hào)
    [subject sendNext:@"1"];
    
  
    
      //1.創(chuàng)建信號(hào)
    RACReplaySubject *replaySubject = [RACReplaySubject subject];
   // RACReplaySubject *replaySubject = [RACReplaySubject replaySubjectWithCapacity:0];
    
    //2.發(fā)送信號(hào)
    [replaySubject sendNext:@1];
    [replaySubject sendNext:@2];
    
    //3.訂閱信號(hào)
    [replaySubject subscribeNext:^(id x) {
        NSLog(@"第一個(gè)訂閱者%@",x);
    }];
    [replaySubject subscribeNext:^(id x) {
        NSLog(@"第二個(gè)訂閱者%@",x);
    }];

RACSubject替代代理

情景：跳轉(zhuǎn)到另一個(gè)ViewController赵誓，TwoViewController發(fā)送通知俩功，ViewController收到回調(diào)的通知

//ViewController里

- (IBAction)click:(UIButton *)sender {

    TwoViewController *twoVC = [[TwoViewController alloc] init];
    
    //設(shè)置代理信號(hào)
    twoVC.delegateSubject = [RACSubject subject];
    
    //訂閱代理信號(hào)
    [twoVC.delegateSubject subscribeNext:^(id x) {
        NSLog(@"點(diǎn)擊了通知按鈕，%@",x);
    }];
    
    //跳轉(zhuǎn)
    [self presentViewController:twoVC animated:YES completion:nil];

}

//TwoViewConrroller里

    if (self.delegateSubject) {
        //發(fā)送信號(hào)
        [self.delegateSubject sendNext:@"已跳轉(zhuǎn)到TwoVC"];
    }
    

遍歷數(shù)組字典诡蜓、字典轉(zhuǎn)模型

RACTuple:元組類,類似NSArray,用來包裝值.

RACSequence: RAC中的集合類蔓罚，用于代替NSArray,NSDictionary,可以使用它來快速遍歷數(shù)組和字典。

    //第一步: 把數(shù)組轉(zhuǎn)換成集合RACSequence             numbers.rac_sequence
    // 第二步: 把集合RACSequence轉(zhuǎn)換RACSignal信號(hào)類    numbers.rac_sequence.signal
    // 第三步: 訂閱信號(hào)豺谈，激活信號(hào)，會(huì)自動(dòng)把集合中的所有值茬末，遍歷出來。    
    // 1.遍歷數(shù)組
    NSArray *numbers = @[@1,@2,@3,@4];
    [numbers.rac_sequence.signal subscribeNext:^(id x) {
        NSLog(@"%@",x);
    }];

    // 2.遍歷字典,遍歷出來的鍵值對(duì)會(huì)包裝成RACTuple(元組對(duì)象)
    NSDictionary *dict = @{@"name":@"xiaoming",@"age":@18};    
    // 解包元組击奶，會(huì)把元組的值柜砾，按順序給參數(shù)里面的變量賦值
    // 相當(dāng)于以下寫法
    //        NSString *key = x[0];
    //        NSString *value = x[1];
    [dict.rac_sequence.signal subscribeNext:^(id x) {
        RACTupleUnpack(NSString *name,NSString *age) = x;
        NSLog(@"%@ %@",name,age);
    }];
    

• 字典轉(zhuǎn)模型

    //1.OC寫法
    NSDictionary *dict1 = @{@"name":@"xiaoming",@"age":@18};
    NSDictionary *dict2 = @{@"name":@"xiaohua",@"age":@20};
    NSArray *arrs = @[dict1,dict2];
    
    NSMutableArray *items = [NSMutableArray array];
    
    for (NSDictionary *dict in arrs) {
        FlagItem *item = [FlagItem flagWithDict:dict];
        [items addObject:item];
    }
    
    //2.RAC寫法
    [arrs.rac_sequence.signal subscribeNext:^(id x) {
        //遍歷RAC字典
        FlagItem *item = [FlagItem flagWithDict:x];
        [items addObject:item];
    }];
    
    //3.高級(jí)RAC寫法
    // map:映射的意思拷橘，目的：把原始值value映射成一個(gè)新值
    // array: 把集合轉(zhuǎn)換成數(shù)組
    // 底層實(shí)現(xiàn)：當(dāng)信號(hào)被訂閱局义，會(huì)遍歷集合中的原始值，映射成新值冗疮，并且保存到新的數(shù)組里萄唇。
    NSArray *flags = [[arrs.rac_sequence map:^id(id value) {
    
        return [FlagItem flagWithDict:value];
    
    }] array];
    NSLog(@"%@",flags);
    

RACCommand

創(chuàng)建并訂閱響應(yīng)action的信號(hào)。 通常command是由UI觸發(fā)的术幔，像一個(gè)按鈕被點(diǎn)擊時(shí)另萤。當(dāng)command被觸發(fā)時(shí)，控件會(huì)?自動(dòng)被禁?诅挑。

有數(shù)據(jù)改變使用RACSignal 有事件處理需要RACCommand

RACCommand設(shè)計(jì)思想：內(nèi)部signalBlock為什么要返回一個(gè)信號(hào)四敞，這個(gè)信號(hào)有什么用。

• 在RAC開發(fā)中拔妥，通常會(huì)把網(wǎng)絡(luò)請(qǐng)求封裝到RACCommand忿危，直接執(zhí)行某個(gè)RACCommand就能發(fā)送請(qǐng)求。

• 當(dāng)RACCommand內(nèi)部請(qǐng)求到數(shù)據(jù)的時(shí)候没龙，需要把請(qǐng)求的數(shù)據(jù)傳遞給外界铺厨，這時(shí)候就需要通過signalBlock返回的信號(hào)傳遞了。

使用場(chǎng)景,監(jiān)聽按鈕點(diǎn)擊硬纤，網(wǎng)絡(luò)請(qǐng)求

   //1.創(chuàng)建命令
    RACCommand *command = [[RACCommand alloc] initWithSignalBlock:^RACSignal *(id input) {
        
        NSLog(@"執(zhí)行命令");
        
        // signalBlock必須要返回一個(gè)信號(hào)，不能傳nil洼裤，如果不想要傳遞信號(hào)腮鞍，直接創(chuàng)建空的信號(hào)缕减。
        //return [RACSignal empty];
        
        //2.創(chuàng)建信號(hào),用來傳遞數(shù)據(jù)
        return [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
            
            [subscriber sendNext:@"請(qǐng)求數(shù)據(jù)"];
            
            //RACCommand中信號(hào)如果數(shù)據(jù)傳遞完，必須調(diào)用[subscriber sendCompleted]皱卓，這時(shí)命令才會(huì)執(zhí)行完畢嫂易，否則永遠(yuǎn)處于執(zhí)行中怜械。
            [subscriber sendCompleted];
        
            return nil;
        }];
    }];
    
    //RACCommand需要被強(qiáng)引用缕允，否則接收不到RACCommand中的信號(hào)，因此RACCommand中的信號(hào)是延遲發(fā)送的驾霜。
    _command = command;
    
    //3.訂閱信號(hào)
    [command.executionSignals subscribeNext:^(id x) {
        
        [x subscribeNext:^(id x) {
            NSLog(@"%@",x);
        }];
    }];
    
    //RAC高級(jí)用法：
    // switchToLatest:用于signal of signals粪糙，獲取signal of signals發(fā)出的最新信號(hào),也就是可以直接拿到RACCommand中的信號(hào),不需要訂閱信號(hào)
    [command.executionSignals.switchToLatest subscribeNext:^(id x) {
        NSLog(@"%@",x);
    }];
    
    //監(jiān)聽命令是否執(zhí)行完畢，默認(rèn)會(huì)來一次洒擦，可以直接跳過,skip表示跳過第一次命令
    [[command.executing skip:1] subscribeNext:^(id x) {
        
        if ([x boolValue] == YES) {
            NSLog(@"正在執(zhí)行");
        }else{
            NSLog(@"執(zhí)行完成");
        }
    }];
    
    
    //4.執(zhí)行命令
    [self.command execute:nil];
    

RACMulticastConnection

用于當(dāng)一個(gè)信號(hào)，被多次訂閱時(shí)掸茅，為了保證創(chuàng)建信號(hào)時(shí)昧狮，避免多次調(diào)用創(chuàng)建信號(hào)中的block合住，造成副作用透葛，可以使用這個(gè)類處理僚害。例如：當(dāng)有2個(gè)RACSignal訂閱信心的時(shí)候，就需要發(fā)送兩次RACSiagnal的信號(hào)岳遥，執(zhí)行兩次block操作。而使用RACMulticastConnection連接帮坚，對(duì)signal pulish處理就不會(huì)多次創(chuàng)建试和。

 //1.創(chuàng)建信號(hào)a
    RACSignal *signal = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
        NSLog(@"發(fā)送請(qǐng)求");
        
        [subscriber sendNext:@1];
        
        return nil;
    }];
    
    //2好渠，創(chuàng)建連接
    RACMulticastConnection *connect = [signal publish];
    
    //3.訂閱信號(hào)。即使訂閱了霍掺，還沒激活信號(hào)
    [connect.signal subscribeNext:^(id x) {
        NSLog(@"訂閱者第一信號(hào)");
    }];
    [connect.signal subscribeNext:^(id x) {
        NSLog(@"訂閱者第二信號(hào)");
    }];
    
    //4.連接牙丽，激活信號(hào)
    [connect connect];

ReactiveCocoa的其他用法

• 代替代理:rac_signalForSelector:用于替代代理。

• 代替KVO :rac_valuesAndChangesForKeyPath:用于監(jiān)聽某個(gè)對(duì)象的屬性改變构罗。

• 監(jiān)聽事件:rac_signalForControlEvents:用于監(jiān)聽某個(gè)事件骄噪。

• 代替通知:rac_addObserverForName:用于監(jiān)聽某個(gè)通知事甜。

• 監(jiān)聽文本框文字改變:rac_textSignal:只要文本框發(fā)出改變就會(huì)發(fā)出這個(gè)信號(hào)。

• 處理當(dāng)界面有多次請(qǐng)求時(shí)邦马，需要都獲取到數(shù)據(jù)時(shí)滋将，才能展示界面

• rac_liftSelector:withSignalsFromArray:Signals:當(dāng)傳入的Signals(信號(hào)數(shù)組)肝谭，每一個(gè)signal都至少sendNext過一次魏滚，就會(huì)去觸發(fā)第一個(gè)selector參數(shù)的方法鼠次。使用注意：幾個(gè)信號(hào)，參數(shù)一的方法就幾個(gè)參數(shù)捕传，每個(gè)參數(shù)對(duì)應(yīng)信號(hào)發(fā)出的數(shù)據(jù)庸论。

// 1.代替代理
// 需求：自定義redView,監(jiān)聽紅色view中按鈕點(diǎn)擊
// 之前都是需要通過代理監(jiān)聽，給紅色View添加一個(gè)代理屬性鱼喉，點(diǎn)擊按鈕的時(shí)候，通知代理做事情
// rac_signalForSelector:把調(diào)用某個(gè)對(duì)象的方法的信息轉(zhuǎn)換成信號(hào)，就要調(diào)用這個(gè)方法掐场，就會(huì)發(fā)送信號(hào)。
// 這里表示只要redV調(diào)用btnClick:,就會(huì)發(fā)出信號(hào)敏弃，訂閱就好了欠肾。
[[redV rac_signalForSelector:@selector(btnClick:)] subscribeNext:^(id x) {
    NSLog(@"點(diǎn)擊紅色按鈕");
}];
// 2.KVO
// 把監(jiān)聽redV的center屬性改變轉(zhuǎn)換成信號(hào)，只要值改變就會(huì)發(fā)送信號(hào)
// observer:可以傳入nil
[[redV rac_valuesAndChangesForKeyPath:@"center" options:NSKeyValueObservingOptionNew observer:nil] subscribeNext:^(id x) {
     
    NSLog(@"%@",x);
     
}];
// 3.監(jiān)聽事件
// 把按鈕點(diǎn)擊事件轉(zhuǎn)換為信號(hào)，點(diǎn)擊按鈕，就會(huì)發(fā)送信號(hào)
[[self.btn rac_signalForControlEvents:UIControlEventTouchUpInside] subscribeNext:^(id x) {
     
    NSLog(@"按鈕被點(diǎn)擊了");
}];
// 4.代替通知
// 把監(jiān)聽到的通知轉(zhuǎn)換信號(hào)
[[[NSNotificationCenter defaultCenter] rac_addObserverForName:UIKeyboardWillShowNotification object:nil] subscribeNext:^(id x) {
    NSLog(@"鍵盤彈出");
}];
// 5.監(jiān)聽文本框的文字改變
[_textField.rac_textSignal subscribeNext:^(id x) {
     
    NSLog(@"文字改變了%@",x);
}];
// 6.處理多個(gè)請(qǐng)求，都返回結(jié)果的時(shí)候，統(tǒng)一做處理.
RACSignal *request1 = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
     
    // 發(fā)送請(qǐng)求1
    [subscriber sendNext:@"發(fā)送請(qǐng)求1"];
    return nil;
}];
RACSignal *request2 = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
    // 發(fā)送請(qǐng)求2
    [subscriber sendNext:@"發(fā)送請(qǐng)求2"];
    return nil;
}];
// 使用注意：幾個(gè)信號(hào)，參數(shù)一的方法就幾個(gè)參數(shù)，每個(gè)參數(shù)對(duì)應(yīng)信號(hào)發(fā)出的數(shù)據(jù)蔗怠。
[self rac_liftSelector:@selector(updateUIWithR1:r2:) withSignalsFromArray:@[request1,request2]];
}
// 更新UI
- (void)updateUIWithR1:(id)data r2:(id)data1
{
    NSLog(@"更新UI%@  %@",data,data1);
}