RAC+MVVM在實(shí)際項(xiàng)目中用法

下載詳細(xì)demo
一個(gè)star一個(gè)摸摸大，客官來吧~
博客地址

RAC在iOS的實(shí)際開發(fā)中確實(shí)是一件有力的武器，此文將從以下幾方面講解

• RACSignal
• RACSubject
• RACSequence
• RACMulticastConnection
• RACCommand
• RAC常用宏
• RAC-bind
• RAC-過濾
• RAC-映射
• RAC-組合
• RAC+MVVM-網(wǎng)絡(luò)請求

RACSignal

 // 1.創(chuàng)建信號(hào)
    RACSignal *signal = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
        // 3.發(fā)送信號(hào)
        [subscriber sendNext:@"ws"];
        // 4.取消信號(hào)，如果信號(hào)想要被取消，就必須返回一個(gè)RACDisposable
        // 信號(hào)什么時(shí)候被取消：1.自動(dòng)取消，當(dāng)一個(gè)信號(hào)的訂閱者被銷毀的時(shí)候機(jī)會(huì)自動(dòng)取消訂閱，2.手動(dòng)取消，
        //block什么時(shí)候調(diào)用：一旦一個(gè)信號(hào)被取消訂閱就會(huì)調(diào)用
        //block作用：當(dāng)信號(hào)被取消時(shí)用于清空一些資源
        return [RACDisposable disposableWithBlock:^{
            NSLog(@"取消訂閱");
        }];
    }];
    // 2. 訂閱信號(hào)
    //subscribeNext
    // 把nextBlock保存到訂閱者里面
    // 只要訂閱信號(hào)就會(huì)返回一個(gè)取消訂閱信號(hào)的類
    RACDisposable *disposable = [signal subscribeNext:^(id x) {
        // block的調(diào)用時(shí)刻：只要信號(hào)內(nèi)部發(fā)出數(shù)據(jù)就會(huì)調(diào)用這個(gè)block
        NSLog(@"======%@", x);
    }];
    // 取消訂閱
    [disposable dispose];

總結(jié)

• .核心：
  • .核心：信號(hào)類
  • .信號(hào)類的作用：只要有數(shù)據(jù)改變就會(huì)把數(shù)據(jù)包裝成信號(hào)傳遞出去
  • .只要有數(shù)據(jù)改變就會(huì)有信號(hào)發(fā)出
  • .數(shù)據(jù)發(fā)出，并不是信號(hào)類發(fā)出，信號(hào)類不能發(fā)送數(shù)據(jù)
• .使用方法：
  • .創(chuàng)建信號(hào)
  • .訂閱信號(hào)
• .實(shí)現(xiàn)思路：
  • .當(dāng)一個(gè)信號(hào)被訂閱，創(chuàng)建訂閱者，并把nextBlock保存到訂閱者里面。
  • .創(chuàng)建的時(shí)候會(huì)返回 [RACDynamicSignal createSignal:didSubscribe];
  • .調(diào)用RACDynamicSignal的didSubscribe
  • .發(fā)送信號(hào)[subscriber sendNext:value];
  • .拿到訂閱者的nextBlock調(diào)用

RACSubject

RACSubject 在使用中我們可以完全代替代理，代碼簡介方法。具體代碼請看demo中的RACSubject。

總結(jié)

我們完全可以用RACSubject代替代理/通知，確實(shí)方便許多
這里我們點(diǎn)擊TwoViewController的pop的時(shí)候 將字符串"ws"傳給了ViewController的button的title。

步驟：

• 1.創(chuàng)建信號(hào)

RACSubject *subject = [RACSubject subject];

• 2.訂閱信號(hào)

[subject subscribeNext:^(id x) {
// block:當(dāng)有數(shù)據(jù)發(fā)出的時(shí)候就會(huì)調(diào)用
// block:處理數(shù)據(jù)
NSLog(@"%@",x);
}];

• 3.發(fā)送信號(hào)

[subject sendNext:value];

• 注意
  RACSubject和RACReplaySubject的區(qū)別
  RACSubject必須要先訂閱信號(hào)之后才能發(fā)送信號(hào)， 而RACReplaySubject可以先發(fā)送信號(hào)后訂閱.
  RACSubject 代碼中體現(xiàn)為：先走TwoViewController的sendNext，后走ViewController的subscribeNext訂閱
  RACReplaySubject 代碼中體現(xiàn)為：先走ViewController的subscribeNext訂閱，后走TwoViewController的sendNext
  可按實(shí)際情況各取所需。

RACSequence

使用場景---： 可以快速高效的遍歷數(shù)組和字典。

 NSString *path = [[NSBundle mainBundle] pathForResource:@"flags.plist" ofType:nil];
    NSArray *dictArr = [NSArray arrayWithContentsOfFile:path];
    [dictArr.rac_sequence.signal subscribeNext:^(id x) {
        NSLog(@"%@", x);
    } error:^(NSError *error) {
        NSLog(@"===error===");
    } completed:^{
        NSLog(@"ok---完畢");
    }];

也可以使用宏

NSDictionary *dict = @{@"key":@1, @"key2":@2};
    [dict.rac_sequence.signal subscribeNext:^(id x) {
        NSLog(@"%@", x);
        NSString *key = x[0];
        NSString *value = x[1];
        // RACTupleUnpack宏：專門用來解析元組
        // RACTupleUnpack 等會(huì)右邊：需要解析的元組 宏的參數(shù)，填解析的什么樣數(shù)據(jù)
        // 元組里面有幾個(gè)值，宏的參數(shù)就必須填幾個(gè)
        RACTupleUnpack(NSString *key, NSString *value) = x;
        NSLog(@"%@ %@", key, value);
    } error:^(NSError *error) {
        NSLog(@"===error");
    } completed:^{
        NSLog(@"-----ok---完畢");
    }];

RACMulticastConnection

當(dāng)有多個(gè)訂閱者，但是我們只想發(fā)送一個(gè)信號(hào)的時(shí)候怎么辦？這時(shí)我們就可以用RACMulticastConnection，來實(shí)現(xiàn)。代碼示例如下

// 普通寫法, 這樣的缺點(diǎn)是：沒訂閱一次信號(hào)就得重新創(chuàng)建并發(fā)送請求，這樣很不友好
 RACSignal *signal = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
        // didSubscribeblock中的代碼都統(tǒng)稱為副作用。
        // 發(fā)送請求---比如afn
        NSLog(@"發(fā)送請求啦");
        // 發(fā)送信號(hào)
        [subscriber sendNext:@"ws"];
        return nil;
    }];
    [signal subscribeNext:^(id x) {
        NSLog(@"%@", x);
    }];
    [signal subscribeNext:^(id x) {
        NSLog(@"%@", x);
    }];
    [signal subscribeNext:^(id x) {
        NSLog(@"%@", x);
    }];

// 比較好的做法。 使用RACMulticastConnection，無論有多少個(gè)訂閱者，無論訂閱多少次，我只發(fā)送一個(gè)。
// 1.發(fā)送請求，用一個(gè)信號(hào)內(nèi)包裝，不管有多少個(gè)訂閱者，只想發(fā)一次請求
    RACSignal *signal = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
        // 發(fā)送請求
        NSLog(@"發(fā)送請求啦");
        // 發(fā)送信號(hào)
        [subscriber sendNext:@"ws"];
        return nil;
    }];
    //2. 創(chuàng)建連接類
    RACMulticastConnection *connection = [signal publish];
    [connection.signal subscribeNext:^(id x) {
        NSLog(@"%@", x);
    }];
    [connection.signal subscribeNext:^(id x) {
         NSLog(@"%@", x);
    }];
    [connection.signal subscribeNext:^(id x) {
         NSLog(@"%@", x);
    }];
    //3. 連接。只有連接了才會(huì)把信號(hào)源變?yōu)闊嵝盘?hào)
    [connection connect];

RACCommand

• RACCommand:RAC中用于處理事件的類，可以把事件如何處理，事件中的數(shù)據(jù)如何傳遞，包裝到這個(gè)類中，他可以很方便的監(jiān)控事件的執(zhí)行過程，比如看事件有沒有執(zhí)行完畢
• 使用場景：監(jiān)聽按鈕點(diǎn)擊，網(wǎng)絡(luò)請求

// 普通做法
// RACCommand: 處理事件
    // 不能返回空的信號(hào)
    // 1.創(chuàng)建命令
    RACCommand *command = [[RACCommand alloc] initWithSignalBlock:^RACSignal *(id input) {
        //block調(diào)用，執(zhí)行命令的時(shí)候就會(huì)調(diào)用
        NSLog(@"%@",input); // input 為執(zhí)行命令傳進(jìn)來的參數(shù)
        // 這里的返回值不允許為nil
        return [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
            [subscriber sendNext:@"執(zhí)行命令產(chǎn)生的數(shù)據(jù)"];
            return nil;
        }];
    }];
    
    // 如何拿到執(zhí)行命令中產(chǎn)生的數(shù)據(jù)呢？
    // 訂閱命令內(nèi)部的信號(hào)
    // ** 方式一：直接訂閱執(zhí)行命令返回的信號(hào)
    
    // 2.執(zhí)行命令
    RACSignal *signal =[command execute:@2]; // 這里其實(shí)用到的是replaySubject 可以先發(fā)送命令再訂閱
    // 在這里就可以訂閱信號(hào)了
    [signal subscribeNext:^(id x) {
        NSLog(@"%@",x);
    }];

// 一般做法
 // 1.創(chuàng)建命令
    RACCommand *command = [[RACCommand alloc] initWithSignalBlock:^RACSignal *(id input) {
        //block調(diào)用，執(zhí)行命令的時(shí)候就會(huì)調(diào)用
        NSLog(@"%@",input); // input 為執(zhí)行命令傳進(jìn)來的參數(shù)
        // 這里的返回值不允許為nil
        return [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
            [subscriber sendNext:@"執(zhí)行命令產(chǎn)生的數(shù)據(jù)"];
            return nil;
        }];
    }];
    
    // 方式二：
    // 訂閱信號(hào)
    // 注意：這里必須是先訂閱才能發(fā)送命令
    // executionSignals：信號(hào)源，信號(hào)中信號(hào)，signalofsignals:信號(hào)，發(fā)送數(shù)據(jù)就是信號(hào)
    [command.executionSignals subscribeNext:^(RACSignal *x) {
        [x subscribeNext:^(id x) {
            NSLog(@"%@", x);
        }];
//        NSLog(@"%@", x);
    }];
    
    // 2.執(zhí)行命令
    [command execute:@2];

// 高級(jí)做法
// 1.創(chuàng)建命令
    RACCommand *command = [[RACCommand alloc] initWithSignalBlock:^RACSignal *(id input) {
        // block調(diào)用：執(zhí)行命令的時(shí)候就會(huì)調(diào)用
        NSLog(@"%@", input);
        // 這里的返回值不允許為nil
        return [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
            [subscriber sendNext:@"發(fā)送信號(hào)"];
            return nil;
        }];
    }];
    
    // 方式三
    // switchToLatest獲取最新發(fā)送的信號(hào)，只能用于信號(hào)中信號(hào)。
    [command.executionSignals.switchToLatest subscribeNext:^(id x) {
        NSLog(@"%@", x);
    }];
    // 2.執(zhí)行命令
    [command execute:@3];

// switchToLatest--用于信號(hào)中信號(hào)
// 創(chuàng)建信號(hào)中信號(hào)
    RACSubject *signalofsignals = [RACSubject subject];
    RACSubject *signalA = [RACSubject subject];
     // 訂閱信號(hào)
//    [signalofsignals subscribeNext:^(RACSignal *x) {
//        [x subscribeNext:^(id x) {
//            NSLog(@"%@", x);
//        }];
//    }];
    // switchToLatest: 獲取信號(hào)中信號(hào)發(fā)送的最新信號(hào)
    [signalofsignals.switchToLatest subscribeNext:^(id x) {
        NSLog(@"%@", x);
    }];
    // 發(fā)送信號(hào)
    [signalofsignals sendNext:signalA];
    [signalA sendNext:@4];

// 監(jiān)聽事件有沒有完成
 //注意：當(dāng)前命令內(nèi)部發(fā)送數(shù)據(jù)完成，一定要主動(dòng)發(fā)送完成
    // 1.創(chuàng)建命令
    RACCommand *command = [[RACCommand alloc] initWithSignalBlock:^RACSignal *(id input) {
        // block調(diào)用：執(zhí)行命令的時(shí)候就會(huì)調(diào)用
        NSLog(@"%@", input);
        // 這里的返回值不允許為nil
        return [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
            // 發(fā)送數(shù)據(jù)
            [subscriber sendNext:@"執(zhí)行命令產(chǎn)生的數(shù)據(jù)"];
            
            // *** 發(fā)送完成 **
            [subscriber sendCompleted];
            return nil;
        }];
    }];
    // 監(jiān)聽事件有沒有完成
    [command.executing subscribeNext:^(id x) {
        if ([x boolValue] == YES) { // 正在執(zhí)行
            NSLog(@"當(dāng)前正在執(zhí)行%@", x);
        }else {
            // 執(zhí)行完成/沒有執(zhí)行
            NSLog(@"執(zhí)行完成/沒有執(zhí)行");
        }
    }];
    
    // 2.執(zhí)行命令
    [command execute:@1];

RAC常用宏

RAC有許多強(qiáng)大而方便的宏。如下

 // RAC:把一個(gè)對(duì)象的某個(gè)屬性綁定一個(gè)信號(hào),只要發(fā)出信號(hào),就會(huì)把信號(hào)的內(nèi)容給對(duì)象的屬性賦值
    // 給label的text屬性綁定了文本框改變的信號(hào)
    RAC(self.label, text) = self.textField.rac_textSignal;
//    [self.textField.rac_textSignal subscribeNext:^(id x) {
//        self.label.text = x;
//    }];

/**
 *  KVO
 *  RACObserveL:快速的監(jiān)聽某個(gè)對(duì)象的某個(gè)屬性改變
 *  返回的是一個(gè)信號(hào),對(duì)象的某個(gè)屬性改變的信號(hào)
 */
 [RACObserve(self.view, center) subscribeNext:^(id x) {
        NSLog(@"%@", x);
    }];

//例 textField輸入的值賦值給label，監(jiān)聽label文字改變,
    RAC(self.label, text) = self.textField.rac_textSignal;
    [RACObserve(self.label, text) subscribeNext:^(id x) {
        NSLog(@"====label的文字變了");
    }];

/**
 *  循環(huán)引用問題
 */
 @weakify(self)
    RACSignal *signal = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
        @strongify(self)
        NSLog(@"%@",self.view);
        return nil;
    }];
    _signal = signal;
使用 @weakify(self)和@strongify(self)來避免循環(huán)引用

/**
 * 元祖
 * 快速包裝一個(gè)元組
 * 把包裝的類型放在宏的參數(shù)里面,就會(huì)自動(dòng)包裝
 */
 RACTuple *tuple = RACTuplePack(@1,@2,@4);
    // 宏的參數(shù)類型要和元祖中元素類型一致， 右邊為要解析的元祖。
    RACTupleUnpack_(NSNumber *num1, NSNumber *num2, NSNumber * num3) = tuple;// 4.元祖
    // 快速包裝一個(gè)元組
    // 把包裝的類型放在宏的參數(shù)里面,就會(huì)自動(dòng)包裝
    NSLog(@"%@ %@ %@", num1, num2, num3);

RAC-bind

// 1.創(chuàng)建信號(hào)
    RACSubject *subject = [RACSubject subject];
    // 2.綁定信號(hào)
   RACSignal *bindSignal = [subject bind:^RACStreamBindBlock{
       // block調(diào)用時(shí)刻：只要綁定信號(hào)訂閱就會(huì)調(diào)用。不做什么事情，
        return ^RACSignal *(id value, BOOL *stop){
            // 一般在這個(gè)block中做事 ，發(fā)數(shù)據(jù)的時(shí)候會(huì)來到這個(gè)block。
            // 只要源信號(hào)（subject）發(fā)送數(shù)據(jù)，就會(huì)調(diào)用block
            // block作用：處理源信號(hào)內(nèi)容
            // value:源信號(hào)發(fā)送的內(nèi)容，
            value = @3; // 如果在這里把value的值改了，那么訂閱綁定信號(hào)的值即44行的x就變了
            NSLog(@"接受到源信號(hào)的內(nèi)容：%@", value);
            //返回信號(hào)，不能為nil,如果非要返回空---則empty或 alloc init。
        return [RACReturnSignal return:value]; // 把返回的值包裝成信號(hào)
        };
    }];

    // 3.訂閱綁定信號(hào)
    [bindSignal subscribeNext:^(id x) {
        
        NSLog(@"接收到綁定信號(hào)處理完的信號(hào):%@", x);
    }];
    // 4.發(fā)送信號(hào)
    [subject sendNext:@"123"];

• 總結(jié)
• bind（綁定）的使用思想和Hook的一樣---> 都是攔截API從而可以對(duì)數(shù)據(jù)進(jìn)行操作，，而影響返回?cái)?shù)據(jù)。
• 發(fā)送信號(hào)的時(shí)候會(huì)來到30行的block。在這個(gè)block里我們可以對(duì)數(shù)據(jù)進(jìn)行一些操作，那么35行打印的value和訂閱綁定信號(hào)后的value就會(huì)變了。變成什么樣隨你喜歡嘍。

RAC-過濾

• 有時(shí)候我們想要過濾一些信號(hào)，這時(shí)候我們便可以用RAC的過濾方法。過濾方法有好多種，如下代碼，從不同情況下進(jìn)行了分析。

// 跳躍 ： 如下，skip傳入2 跳過前面兩個(gè)值
// 實(shí)際用處： 在實(shí)際開發(fā)中比如 后臺(tái)返回的數(shù)據(jù)前面幾個(gè)沒用，我們想跳躍過去，便可以用skip
 RACSubject *subject = [RACSubject subject];
    [[subject skip:2] subscribeNext:^(id x) {
        NSLog(@"%@", x);
    }];
    [subject sendNext:@1];
    [subject sendNext:@2];
    [subject sendNext:@3];

//distinctUntilChanged:-- 如果當(dāng)前的值跟上一次的值一樣，就不會(huì)被訂閱到
    RACSubject *subject = [RACSubject subject];
    [[subject distinctUntilChanged] subscribeNext:^(id x) {
        NSLog(@"%@", x);
    }];
    // 發(fā)送信號(hào)
    [subject sendNext:@1];
    [subject sendNext:@2];
    [subject sendNext:@2]; // 不會(huì)被訂閱

// take:可以屏蔽一些值,去掉前面幾個(gè)值---這里take為2 則只拿到前兩個(gè)值
RACSubject *subject = [RACSubject subject];
    [[subject take:2] subscribeNext:^(id x) {
        NSLog(@"%@", x);
    }];
    // 發(fā)送信號(hào)
    [subject sendNext:@1];
    [subject sendNext:@2];
    [subject sendNext:@3];

//takeLast:和take的用法一樣，不過他取的是最后的幾個(gè)值，如下，則取的是最后兩個(gè)值
//注意點(diǎn):takeLast 一定要調(diào)用sendCompleted，告訴他發(fā)送完成了，這樣才能取到最后的幾個(gè)值
RACSubject *subject = [RACSubject subject];
    [[subject takeLast:2] subscribeNext:^(id x) {
        NSLog(@"%@", x);
    }];
    // 發(fā)送信號(hào)
    [subject sendNext:@1];
    [subject sendNext:@2];
    [subject sendNext:@3];
    [subject sendCompleted];

// takeUntil:---給takeUntil傳的是哪個(gè)信號(hào)，那么當(dāng)這個(gè)信號(hào)發(fā)送信號(hào)或sendCompleted，就不能再接受源信號(hào)的內(nèi)容了。
 RACSubject *subject = [RACSubject subject];
    RACSubject *subject2 = [RACSubject subject];
    [[subject takeUntil:subject2] subscribeNext:^(id x) {
        NSLog(@"%@", x);
    }];
    // 發(fā)送信號(hào)
    [subject sendNext:@1];
    [subject sendNext:@2];
    [subject2 sendNext:@3];  // 1
//    [subject2 sendCompleted]; // 或2
    [subject sendNext:@4];

// ignore: 忽略掉一些值
 //ignore:忽略一些值
    //ignoreValues:表示忽略所有的值
    // 1.創(chuàng)建信號(hào)
    RACSubject *subject = [RACSubject subject];
    // 2.忽略一些值
    RACSignal *ignoreSignal = [subject ignore:@2]; // ignoreValues:表示忽略所有的值
    // 3.訂閱信號(hào)
    [ignoreSignal subscribeNext:^(id x) {
        NSLog(@"%@", x);
    }];
    // 4.發(fā)送數(shù)據(jù)
    [subject sendNext:@2];

// 一般和文本框一起用，添加過濾條件
// 只有當(dāng)文本框的內(nèi)容長度大于5，才獲取文本框里的內(nèi)容
    [[self.textField.rac_textSignal filter:^BOOL(id value) {
        // value 源信號(hào)的內(nèi)容
        return [value length] > 5;
        // 返回值 就是過濾條件。只有滿足這個(gè)條件才能獲取到內(nèi)容
    }] subscribeNext:^(id x) {
        NSLog(@"%@", x);
    }];

RAC-映射

• RAC的映射在實(shí)際開發(fā)中有什么用呢？比如我們想要攔截服務(wù)器返回的數(shù)據(jù)，給數(shù)據(jù)拼接特定的東西或想對(duì)數(shù)據(jù)進(jìn)行操作從而更改返回值，類似于這樣的情況下，我們便可以考慮用RAC的映射，實(shí)例代碼如下

- (void)map {
    // 創(chuàng)建信號(hào)
    RACSubject *subject = [RACSubject subject];
    // 綁定信號(hào)
    RACSignal *bindSignal = [subject map:^id(id value) {
        
        // 返回的類型就是你需要映射的值
        return [NSString stringWithFormat:@"ws:%@", value]; //這里將源信號(hào)發(fā)送的“123” 前面拼接了ws：
    }];
    // 訂閱綁定信號(hào)
    [bindSignal subscribeNext:^(id x) {
        NSLog(@"%@", x);
    }];
    // 發(fā)送信號(hào)
    [subject sendNext:@"123"];

 - (void)flatMap {
    // 創(chuàng)建信號(hào)
    RACSubject *subject = [RACSubject subject];
    // 綁定信號(hào)
    RACSignal *bindSignal = [subject flattenMap:^RACStream *(id value) {
        // block：只要源信號(hào)發(fā)送內(nèi)容就會(huì)調(diào)用
        // value: 就是源信號(hào)發(fā)送的內(nèi)容
        // 返回信號(hào)用來包裝成修改內(nèi)容的值
        return [RACReturnSignal return:value];
        
    }];
    
    // flattenMap中返回的是什么信號(hào)，訂閱的就是什么信號(hào)(那么，x的值等于value的值，如果我們操縱value的值那么x也會(huì)隨之而變)
    // 訂閱信號(hào)
    [bindSignal subscribeNext:^(id x) {
        NSLog(@"%@", x);
    }];
    
    // 發(fā)送數(shù)據(jù)
    [subject sendNext:@"123"];
    
}

- (void)flattenMap2 {
    // flattenMap 主要用于信號(hào)中的信號(hào)
    // 創(chuàng)建信號(hào)
    RACSubject *signalofSignals = [RACSubject subject];
    RACSubject *signal = [RACSubject subject];
    
    // 訂閱信號(hào)
    //方式1
    //    [signalofSignals subscribeNext:^(id x) {
    //
    //        [x subscribeNext:^(id x) {
    //            NSLog(@"%@", x);
    //        }];
    //    }];
    // 方式2
    //    [signalofSignals.switchToLatest  ];
    // 方式3
    //   RACSignal *bignSignal = [signalofSignals flattenMap:^RACStream *(id value) {
    //
    //        //value:就是源信號(hào)發(fā)送內(nèi)容
    //        return value;
    //    }];
    //    [bignSignal subscribeNext:^(id x) {
    //        NSLog(@"%@", x);
    //    }];
    // 方式4--------也是開發(fā)中常用的
    [[signalofSignals flattenMap:^RACStream *(id value) {
        return value;
    }] subscribeNext:^(id x) {
        NSLog(@"%@", x);
    }];
    
    // 發(fā)送信號(hào)
    [signalofSignals sendNext:signal];
    [signal sendNext:@"123"];
}

RAC-組合

• 把多個(gè)信號(hào)聚合成你想要的信號(hào),使用場景----：比如-當(dāng)多個(gè)輸入框都有值的時(shí)候按鈕才可點(diǎn)擊。

// 思路--- 就是把輸入框輸入值的信號(hào)都聚合成按鈕是否能點(diǎn)擊的信號(hào)。
- (void)combineLatest {
    
    RACSignal *combinSignal = [RACSignal combineLatest:@[self.accountField.rac_textSignal, self.pwdField.rac_textSignal] reduce:^id(NSString *account, NSString *pwd){ //reduce里的參數(shù)一定要和combineLatest數(shù)組里的一一對(duì)應(yīng)。
        // block: 只要源信號(hào)發(fā)送內(nèi)容，就會(huì)調(diào)用，組合成一個(gè)新值。
        NSLog(@"%@ %@", account, pwd);
        return @(account.length && pwd.length);
    }];
    
    //    // 訂閱信號(hào)
    //    [combinSignal subscribeNext:^(id x) {
    //        self.loginBtn.enabled = [x boolValue];
    //    }];    // ----這樣寫有些麻煩，可以直接用RAC宏
    RAC(self.loginBtn, enabled) = combinSignal;
}

- (void)zipWith {
    //zipWith:把兩個(gè)信號(hào)壓縮成一個(gè)信號(hào)，只有當(dāng)兩個(gè)信號(hào)同時(shí)發(fā)出信號(hào)內(nèi)容時(shí)，并且把兩個(gè)信號(hào)的內(nèi)容合并成一個(gè)元祖，才會(huì)觸發(fā)壓縮流的next事件。
    // 創(chuàng)建信號(hào)A
    RACSubject *signalA = [RACSubject subject];
    // 創(chuàng)建信號(hào)B
    RACSubject *signalB = [RACSubject subject];
    // 壓縮成一個(gè)信號(hào)
    // **-zipWith-**: 當(dāng)一個(gè)界面多個(gè)請求的時(shí)候，要等所有請求完成才更新UI
    // 等所有信號(hào)都發(fā)送內(nèi)容的時(shí)候才會(huì)調(diào)用
    RACSignal *zipSignal = [signalA zipWith:signalB];
    [zipSignal subscribeNext:^(id x) {
        NSLog(@"%@", x); //所有的值都被包裝成了元組
    }];
    
    // 發(fā)送信號(hào) 交互順序，元組內(nèi)元素的順序不會(huì)變，跟發(fā)送的順序無關(guān)，而是跟壓縮的順序有關(guān)[signalA zipWith:signalB]---先是A后是B
    [signalA sendNext:@1];
    [signalB sendNext:@2];

}

// 任何一個(gè)信號(hào)請求完成都會(huì)被訂閱到
// merge:多個(gè)信號(hào)合并成一個(gè)信號(hào)，任何一個(gè)信號(hào)有新值就會(huì)調(diào)用
- (void)merge {
    // 創(chuàng)建信號(hào)A
    RACSubject *signalA = [RACSubject subject];
    // 創(chuàng)建信號(hào)B
    RACSubject *signalB = [RACSubject subject];
    //組合信號(hào)
    RACSignal *mergeSignal = [signalA merge:signalB];
    // 訂閱信號(hào)
    [mergeSignal subscribeNext:^(id x) {
        NSLog(@"%@", x);
    }];
    // 發(fā)送信號(hào)---交換位置則數(shù)據(jù)結(jié)果順序也會(huì)交換
    [signalB sendNext:@"下部分"];
    [signalA sendNext:@"上部分"];
}

// then --- 使用需求：有兩部分?jǐn)?shù)據(jù)：想讓上部分先進(jìn)行網(wǎng)絡(luò)請求但是過濾掉數(shù)據(jù)，然后進(jìn)行下部分的，拿到下部分?jǐn)?shù)據(jù)
- (void)then {
    // 創(chuàng)建信號(hào)A
    RACSignal *signalA = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
        // 發(fā)送請求
        NSLog(@"----發(fā)送上部分請求---afn");
        
        [subscriber sendNext:@"上部分?jǐn)?shù)據(jù)"];
        [subscriber sendCompleted]; // 必須要調(diào)用sendCompleted方法！
        return nil;
    }];
    
    // 創(chuàng)建信號(hào)B，
    RACSignal *signalsB = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
        // 發(fā)送請求
        NSLog(@"--發(fā)送下部分請求--afn");
        [subscriber sendNext:@"下部分?jǐn)?shù)據(jù)"];
        return nil;
    }];
    // 創(chuàng)建組合信號(hào)
    // then;忽略掉第一個(gè)信號(hào)的所有值
    RACSignal *thenSignal = [signalA then:^RACSignal *{
        // 返回的信號(hào)就是要組合的信號(hào)
        return signalsB;
    }];
    
    // 訂閱信號(hào)
    [thenSignal subscribeNext:^(id x) {
        NSLog(@"%@", x);
    }];

}

// concat----- 使用需求：有兩部分?jǐn)?shù)據(jù)：想讓上部分先執(zhí)行，完了之后再讓下部分執(zhí)行（都可獲取值）
- (void)concat {
    // 組合
    
    // 創(chuàng)建信號(hào)A
    RACSignal *signalA = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
        // 發(fā)送請求
        //        NSLog(@"----發(fā)送上部分請求---afn");
        
        [subscriber sendNext:@"上部分?jǐn)?shù)據(jù)"];
        [subscriber sendCompleted]; // 必須要調(diào)用sendCompleted方法！
        return nil;
    }];
    
    // 創(chuàng)建信號(hào)B，
    RACSignal *signalsB = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
        // 發(fā)送請求
        //        NSLog(@"--發(fā)送下部分請求--afn");
        [subscriber sendNext:@"下部分?jǐn)?shù)據(jù)"];
        return nil;
    }];
    
    
    // concat:按順序去鏈接
    //**-注意-**：concat，第一個(gè)信號(hào)必須要調(diào)用sendCompleted
    // 創(chuàng)建組合信號(hào)
    RACSignal *concatSignal = [signalA concat:signalsB];
    // 訂閱組合信號(hào)
    [concatSignal subscribeNext:^(id x) {
        NSLog(@"%@",x);
    }];

}

RAC+MVVM-網(wǎng)絡(luò)請求

請看demo
下載demo