ReactiveCocoa（3）高級用法

這篇主要運(yùn)用RACSubject

先復(fù)習(xí)下第一篇中說到的RACSubject，話不多說，上來就是RAC三部曲

//創(chuàng)建信號
RACSubject *subject = [RACSubject subject];
//訂閱信號
[subject subscribeNext:^(id  _Nullable x) {
    NSLog(@"%@",x);
}];
//發(fā)送信號
[subject sendNext:@"en"];

OK，切入正題

一、flattenMap, Map 映射

這兩個(gè)方法就是將我們的信號源的內(nèi)容應(yīng)設(shè)成一個(gè)新的信號。

之前我們就有提到過，我們?yōu)槭裁匆壎ㄐ盘枺?strong>就是要在信號發(fā)過來之前對信號進(jìn)行處理，那么在這里我們要對他進(jìn)行的處理就是映射。

所以現(xiàn)在我們要對他返回一個(gè)信號，之前我們提過要返回的話我們要導(dǎo)入一個(gè)頭文件。#import “RACReturnSignal.h"

接下來我們來使用這個(gè)return
return [RACReturnSignal return:(id)];

完整代碼如下

//創(chuàng)建信號
RACSubject *subject = [RACSubject subject];

//flattenMap, map 映射
//返回一個(gè)信號源
[[subject flattenMap:^__kindof RACSignal * _Nullable(id  _Nullable value) {
    
    NSString *valueStr = [NSString stringWithFormat:@"被處理過的 %@ 數(shù)據(jù)",value];
    return [RACReplaySubject return:valueStr];
}] subscribeNext:^(id  _Nullable x) {
    NSLog(@"%@",x);
}];

//發(fā)送信號
[subject sendNext:@"123"];

但是有沒有覺得有點(diǎn)麻煩，有點(diǎn)繞??！好我們有請Map代替flattenMap！！

[[subject map:^id _Nullable(id  _Nullable value) {
    NSString *valueStr = [NSString stringWithFormat:@"被處理過的 %@ 數(shù)據(jù)",value];
    return valueStr;
}] subscribeNext:^(id  _Nullable x) {
    NSLog(@"%@",x);
}];

這時(shí)候有沒有覺得簡單了好多！

那么問題來了！既然map 這么簡單，為什么我們還要有flattenMap 呢？

他當(dāng)然有他的特殊的地方了，通常 flattenMap 用在處理信號中的信號！我們再來看一下。

先來幾個(gè)信號
RACSubject * subjectOfSignal = [RACSubject subject]; RACSubject * subject1 = [RACSubject subject];

然后我們發(fā)送信號
[subjectOfSignal sendNext:subject1]; [subject1 sendNext:@"data1″];

這邊我們讓一個(gè)信號發(fā)送數(shù)據(jù)，然后另一個(gè)信號發(fā)送這個(gè)信號。

所以說 subjectOfSignal 就是我們的信號源～我們今天要拿到data1 又不能直接訂閱signal1 的話就要對 subjectOfSignal 進(jìn)行處理了！
在第二篇中我們有說到過訂閱信號中的信號用switchToLatest

//創(chuàng)建多個(gè)信號
RACSubject *signalOfSignal = [RACSubject subject];//信號中的信號
RACSubject *signal1 = [RACSubject subject];

[signalOfSignal.switchToLatest subscribeNext:^(id  _Nullable x) {
    NSLog(@"%@",x);
}];

//發(fā)送信號
[signalOfSignal sendNext:signal1];
[signal1 sendNext:@"data"];

這次我們說一個(gè)新的用法，那就是flattenMap來代替switchToLatest，如下

[[signalOfSignal flattenMap:^__kindof RACSignal * _Nullable(id  _Nullable value) {
    return value;
}] subscribeNext:^(id  _Nullable x) {
    NSLog(@"%@",x);
}];

二、RAC信號組合

在我們開發(fā)中，比如一個(gè)頁面不可能只會需要一個(gè)信號吧，這就需要用到我們RAC中的信號組合：
1、concat 按照順序組合的信號

//RAC信號組合
//1、concat 按照順序組合的信號
RACSignal * signal1 = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
    
    NSLog(@"發(fā)送請求 1");
    
    [subscriber sendNext:@"data1"];
    [subscriber sendCompleted]; //發(fā)送完畢
    return nil;
}];

RACSignal * signal2 = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
    
    NSLog(@"發(fā)送請求 2");
    [subscriber sendNext:@"data2"];
    [subscriber sendCompleted]; //發(fā)送完畢
    return nil;
}];

RACSignal * signal3 = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
    
    NSLog(@"發(fā)送請求 3");
    [subscriber sendNext:@"data3"];
    [subscriber sendCompleted];
    return nil;
}];


[[RACSignal concat:@[signal3,signal2,signal1]] subscribeNext:^(id  _Nullable x) {
    NSLog(@"%@",x);
}];

2、zipWith
zip字面有壓縮之意。
多個(gè)信號組合，當(dāng)他組合的兩個(gè)信號，同時(shí)發(fā)送了信息頭，他會回傳一個(gè)元祖。
開發(fā)中的需求比如讓一個(gè)圖片和名字同事顯示。

//zipWith: 多個(gè)信號組合，當(dāng)他組合的兩個(gè)信號，同時(shí)發(fā)送了信息頭，他會回傳一個(gè)元祖
RACSubject * subject1 = [RACSubject subject];
RACSubject * subject2 = [RACSubject subject];

//壓縮信號
RACSignal * zipSignal = [subject1 zipWith:subject2];
[zipSignal subscribeNext:^(id  _Nullable x) {
    NSLog(@"%@",x);
}];


[subject1 sendNext:@"data1"];
[subject2 sendNext:@"data2"];

[subject1 sendNext:@"data11"];
[subject2 sendNext:@"data22"];

[subject1 sendNext:@"data111"];
[subject2 sendNext:@"data222"];

三、RAC忽略、過濾

1、then 忽略

//then 忽略
    RACSignal * signal1 = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        
        NSLog(@"發(fā)送請求 1");
        
        [subscriber sendNext:@"data1"];
        [subscriber sendCompleted];
        return nil;
    }];
    
    RACSignal * signal2 = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        
        NSLog(@"發(fā)送請求 2");
        [subscriber sendNext:@"data2"];
        
        return nil;
    }];
    //當(dāng)signal1 發(fā)送完畢后  忽略  data1 發(fā)送 signal2
    [[signal1 then:^RACSignal * _Nonnull{
        return signal2;
    }] subscribeNext:^(id  _Nullable x) {
        NSLog(@"%@",x);
    }];

2、ignore指定忽略 某個(gè)／某些 信號

// ignore
RACSubject * subject = [RACSubject subject];
//    忽略一些值
//    [[subject ignore:@"data1"] subscribeNext:^(id  _Nullable x) {
//        NSLog(@"%@",x);
//    }];
//    忽略所有值
//    [[subject ignoreValues] subscribeNext:^(id  _Nullable x) {
//        NSLog(@"%@",x);
//    }];
//    忽略某些值
[[[subject ignore:@"data1"] ignore:@"data2"] subscribeNext:^(id  _Nullable x) {
    NSLog(@"%@",x);
    //打印出來的只有data3
}];

[subject sendNext:@"data1"];
[subject sendNext:@"data2"];
[subject sendNext:@"data3"];

3、take指定訂閱，忽略掉其他的
take : 指定訂閱（從前到后）前幾個(gè)
takeLast: (從后到前) 后幾個(gè)

//take
RACSubject * subject  = [RACSubject subject];

//take : 指定訂閱（從前到后）前幾個(gè)
[[subject take:3] subscribeNext:^(id  _Nullable x) {
    NSLog(@"%@",x);
    //打?。篸ata1，data2，data3
}];

//takeLast: (從后到前) 后幾個(gè)
[[subject takeLast:2] subscribeNext:^(id  _Nullable x) {
    NSLog(@"%@",x);
    //打?。篸ata3，data4
}];

[subject sendNext:@"data1"];
[subject sendNext:@"data2"];
[subject sendNext:@"data3"];
[subject sendNext:@"data4"];
[subject sendCompleted];

4、take的高級用法takeUntil
字面意思直到

//take的高級用法takeUntil直到
RACSubject * subject1 = [RACSubject subject];
RACSubject * subject2 = [RACSubject subject];
[[subject1 takeUntil:subject2] subscribeNext:^(id  _Nullable x) {
    NSLog(@"%@",x);
    //打印：data1，data2，data3
}];

[subject1 sendNext:@"data1"];
[subject1 sendNext:@"data2"];
[subject1 sendNext:@"data3"];
[subject2 sendNext:@"STOP"];
[subject1 sendNext:@"data4"];

5、distinctUntilChange 過濾到重復(fù)的信號
在我們實(shí)際開發(fā)中有很多重復(fù)的信號，這就用到過濾的高級用法distinctUntilChange

//distinctUntilChange 過濾到重復(fù)的信號
RACSubject * subject1 = [RACSubject subject];


[[subject1 distinctUntilChanged] subscribeNext:^(id  _Nullable x) {
    NSLog(@"%@",x);
    //打印 ： data1 data12
}];

[subject1 sendNext:@"data1"];
[subject1 sendNext:@"data1"];
[subject1 sendNext:@"data12"];
[subject1 sendNext:@"data12"];

以上就是RAC中主要的一些用法了，要想掌握主要還是需要平時(shí)多練多寫，不理解的點(diǎn)進(jìn)去看看源代碼，捋一下！

上述代碼可以到我的GitHub中下載

有錯(cuò)誤，有問題的歡迎提出來！??

最后編輯于 ：
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成，瀏覽時(shí)請結(jié)合常識與多方信息審慎甄別。
平臺聲明：文章內(nèi)容（如有圖片或視頻亦包括在內(nèi)）由作者上傳并發(fā)布，文章內(nèi)容僅代表作者本人觀點(diǎn)，簡書系信息發(fā)布平臺，僅提供信息存儲服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容