RAC初探

函數(shù)式編程

主要思想是把運(yùn)算過(guò)程盡量寫成一系列嵌套的函數(shù)調(diào)用
特點(diǎn)

  • 函數(shù)式編程要求只使用表達(dá)式,不使用語(yǔ)句捡遍。也就是說(shuō),每一步都是單純的運(yùn)算竹握,而且都有返回值画株。
  • 函數(shù)的運(yùn)行不依賴于外部變量狀態(tài),只依賴于輸入的參數(shù)涩搓,任何時(shí)候只要參數(shù)相同污秆,引用函數(shù)所得到的返回值總是相同的。
響應(yīng)式編程

例如昧甘,在命令式編程環(huán)境中a = b + c表示將表達(dá)式的結(jié)果賦給 a良拼,而之后改變 b 或 c 的值不會(huì)影響 a。但在響應(yīng)式編程中充边,a 的值會(huì)隨著 b 或 c 的更新而更新庸推。
在響應(yīng)式編程當(dāng)中,a = b + c聲明的是一種綁定關(guān)系浇冰。(a 與 b贬媒、c 綁定起來(lái)了,所以 b肘习、c 的變化會(huì)影響 a际乘,這也就是所謂變化傳播

什么是RAC?

RAC其實(shí)就是一個(gè)三方庫(kù)ReactiveObjC漂佩,只不過(guò)在這個(gè)庫(kù)中把蘋果的消息響應(yīng)機(jī)制給整合了脖含。RAC是函數(shù)式響應(yīng)式編程(簡(jiǎn)稱FRP)。它能給我們解決什么問(wèn)題呢投蝉,首先它能在某些情況大大減少代碼量养葵,然后把響應(yīng)事件的觸發(fā)整和到一起,通過(guò)block回調(diào)的形式觸發(fā)瘩缆。
我們常用的Target-Action关拒、KVO通知代理等一些操作都可以用RAC進(jìn)行替代着绊。

RAC框架結(jié)構(gòu)
RAC的導(dǎo)入

這里使用cocoaPods導(dǎo)入谐算,版本是3.0.0。在Podfile文件里寫入pod 'ReactiveObjC', '~> 3.0.0'畔柔,再在命令行中執(zhí)行pod install氯夷,項(xiàng)目中引入<ReactiveObjC.h> 頭文件即可開(kāi)始使用臣樱。

RAC初級(jí)用法

KVO監(jiān)聽(tīng)name屬性變化

KVO正常使用

// 聲明name屬性
@property (nonatomic, copy) NSString *name;

// 添加監(jiān)聽(tīng)addObserver
[self addObserver:self forKeyPath:@"name" options:(NSKeyValueObservingOptionNew) context:NULL];

// 在方法 observeValueForKeyPath中實(shí)現(xiàn)監(jiān)聽(tīng)到屬性值變化后的處理
- (void)observeValueForKeyPath:(NSString *)keyPath ofObject:(id)object change:(NSDictionary<NSKeyValueChangeKey,id> *)change context:(void *)context {
    if ([@"name" isEqualToString: keyPath]) {
        NSLog(@"%@", change);
    }
}

// 在析構(gòu)函數(shù)中移除監(jiān)聽(tīng)removeObserver
- (void)dealloc {
    [self removeObserver:self forKeyPath:@"name"];
}

// 觸發(fā)按鈕等方式修改name屬性值
self.name = @"hello world";

// 日志打印
2022-11-02 22:58:42.677795+0800 001---RAC初探[27850:25205494] {
    kind = 1;
    new = "hello world";
}

RAC使用

// RAC的好處
// 1. 有好的提示
// 2. 代碼簡(jiǎn)潔
// 3. 代碼邏輯與功能邏輯集中在一塊靶擦,方便閱讀
// 4. 不需要在dealloc方法中移除監(jiān)聽(tīng)
self.name = @"hello world";
[RACObserve(self, name) subscribeNext:^(id  _Nullable x) {
    NSLog(@"%@",x);
}];
通知 NSNotificationCenter

通知正常使用

// 添加鍵盤彈出的通知addObserver
[[NSNotificationCenter defaultCenter] addObserver:self
                                             selector:@selector(keyboardWillShow:)
                                                 name:UIKeyboardWillShowNotification
                                               object:nil];

// 實(shí)現(xiàn)通知 keyboardWillShow
- (void) keyboardWillShow:(NSNotification *)note {
    NSLog(@"鍵盤彈出了");
}

// 在析構(gòu)函數(shù)中移除通知removeObserver
[[NSNotificationCenter defaultCenter] removeObserver:self name:UIKeyboardWillShowNotification object:nil];

RAC使用

[[[NSNotificationCenter defaultCenter] rac_addObserverForName:UIKeyboardWillShowNotification object:nil] subscribeNext:^(NSNotification * _Nullable x) {
    NSLog(@"%@",x);
}];
代理 delegate

代理正常使用

// 以 UITextField 的 textFieldDidBeginEditing 代理為例
self.textField.delegate = self;

// 代理方法
- (void)textFieldDidBeginEditing:(UITextField *)textField {
    NSLog(@"開(kāi)始編輯");
}

RAC使用

[[self rac_signalForSelector:@selector(textFieldDidBeginEditing:) fromProtocol:@protocol(UITextFieldDelegate)] subscribeNext:^(RACTuple * _Nullable x) {
    NSLog(@"%@",x);
}];
self.textField.delegate = self;
UIButton 按鈕點(diǎn)擊事件

按鈕點(diǎn)擊正常使用

// 為按鈕添加方法 addTarget
[self.button addTarget:self action:@selector(onBtnClick:) forControlEvents:UIControlEventTouchUpInside];

// 實(shí)現(xiàn)按鈕的點(diǎn)擊方法onBtnClick
- (void)onBtnClick:(UIButton *)sender {
    NSLog(@"點(diǎn)擊按鈕了");
}

RAC使用

[[self.button rac_signalForControlEvents:UIControlEventTouchUpInside] subscribeNext:^(__kindof UIControl * _Nullable x) {
    NSLog(@"%@",x);
}];
UITextField監(jiān)聽(tīng)輸入內(nèi)容

RAC使用監(jiān)聽(tīng)TextField輸入的內(nèi)容

[self.textField.rac_textSignal subscribeNext:^(NSString * _Nullable x) {
    NSLog(@"%@",x);
}];

// textField輸入內(nèi)容,控制臺(tái)打印信息如下
2022-11-07 22:53:43.285177+0800 001---RAC初探[2122:58239] 1
2022-11-07 22:53:43.454581+0800 001---RAC初探[2122:58239] 11
2022-11-07 22:53:43.647145+0800 001---RAC初探[2122:58239] 111
手勢(shì) UITapGestureRecognizer

RAC使用

UITapGestureRecognizer *tap = [[UITapGestureRecognizer alloc] init];
self.label.userInteractionEnabled = YES;
[self.label addGestureRecognizer:tap];

[tap.rac_gestureSignal subscribeNext:^(__kindof UIGestureRecognizer * _Nullable x) {
    NSLog(@"%@",x);
}];

信號(hào)的產(chǎn)生是一個(gè)冷信號(hào)雇毫,只有訂閱了才是熱信號(hào)玄捕,subscribeNext回調(diào)就相當(dāng)于訂閱信號(hào)。

數(shù)組和字典的遍歷 - 序列sequence
  • RAC遍歷數(shù)組
NSArray *array = @[@"aaa",@"bbb",@"ccc"];
    
[array.rac_sequence.signal subscribeNext:^(id  _Nullable x) {
    NSLog(@"%@",x);
}];

// 打印日志
2022-11-07 23:06:13.476959+0800 001---RAC初探[2381:66330] aaa
2022-11-07 23:06:13.477248+0800 001---RAC初探[2381:66330] bbb
2022-11-07 23:06:13.477466+0800 001---RAC初探[2381:66330] ccc
  • RAC遍歷字典
NSDictionary *dict = @{@"key":@"小明",@"age":@"18",@"gender":@"1"};
    
[dict.rac_sequence.signal subscribeNext:^(id  _Nullable x) {
    //元祖
    NSLog(@"%@",x);
    RACTwoTuple *tuple = (RACTwoTuple *)x;
    NSLog(@"key == %@ , value = %@",tuple[0],tuple[1]);
}];

// 打印日志
2022-11-07 23:07:10.594735+0800 001---RAC初探[2425:67567] <RACTwoTuple: 0x6000012f8660> (
    key,
    "\U5c0f\U660e"
)
2022-11-07 23:07:10.595465+0800 001---RAC初探[2425:67567] key == key , value = 小明
2022-11-07 23:07:10.597160+0800 001---RAC初探[2425:67567] <RACTwoTuple: 0x6000012f4680> (
    age,
    18
)
2022-11-07 23:07:10.597699+0800 001---RAC初探[2425:67567] key == age , value = 18
2022-11-07 23:07:10.598388+0800 001---RAC初探[2425:67567] <RACTwoTuple: 0x6000012f04b0> (
    gender,
    1
)
2022-11-07 23:07:10.598682+0800 001---RAC初探[2425:67567] key == gender , value = 1
RAC最基本的用法流程

創(chuàng)建信號(hào)棚放、訂閱信號(hào)枚粘、發(fā)送信號(hào)

//1:創(chuàng)建信號(hào)
RACSignal *signal = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
    //subscriber 對(duì)象不是一個(gè)對(duì)象
    //3:發(fā)送信號(hào)
    [subscriber sendNext:@"hello world"];
        
    //請(qǐng)求網(wǎng)絡(luò) 失敗 error
    NSError *error = [NSError errorWithDomain:NSURLErrorDomain code:10086 userInfo:@{@"key":@"10086錯(cuò)誤"}];
    [subscriber sendError:error];

    // RACDisposable 銷毀
    return [RACDisposable disposableWithBlock:^{
        NSLog(@"銷毀了");
    }];
}];

//2:訂閱信號(hào)
[signal subscribeNext:^(id  _Nullable x) {
    NSLog(@"%@",x);
}];
//訂閱錯(cuò)誤信號(hào)
[signal subscribeError:^(NSError * _Nullable error) {
    NSLog(@"%@",error);
}];

RAC綁定UI簡(jiǎn)單使用

  • UIImageView的顯示隨著UITextField輸入的內(nèi)容而改變
// 圖片綁定在textField上
@weakify(self);
[self.textField.rac_textSignal subscribeNext:^(NSString * _Nullable x) {
    @strongify(self);
    self.imageView.image = [UIImage imageNamed:[NSString stringWithFormat:"%@", x]];
}];
  • 點(diǎn)擊按鈕檢測(cè)UITextField輸入內(nèi)容是否正確
[[self.button rac_signalForControlEvents: UIControlEventTouchUpInside] subscribeNext:^(__kindof UIControl * _Nullable x) {
    if ([self.textField.text isEqualToString:@"123"]) {
        NSLog(@"fail");
    } else {
        NSLog(@"success");
    }
}];

通過(guò)綁定UI正向傳遞數(shù)據(jù):通過(guò)綁定UI,一旦UI發(fā)生任何變化就會(huì)形成信號(hào)飘蚯,有了信號(hào)我們就可以訂閱馍迄,最后可以在訂閱里面做綁定過(guò)來(lái)的事件的回調(diào)

RAC高階函數(shù)

  • 信號(hào)映射mapflattenMap
  • 信號(hào)過(guò)濾filter局骤、ignore攀圈、distinctUntilChanged
  • 信號(hào)合并combineLatestreduce峦甩、merge赘来、zipWith
  • 信號(hào)連接concatthen
  • 信號(hào)操作時(shí)間timeout凯傲、interval犬辰、dely
  • 信號(hào)取值taketakeLast冰单、takeUntil
  • 信號(hào)跳過(guò)skip
  • 信號(hào)發(fā)送順序donext幌缝、cocompleted
  • 獲取信號(hào)中的信號(hào)switchToLatest
  • 信號(hào)錯(cuò)誤重試retry
信號(hào)映射

flattenMap作用:
把源信號(hào)的內(nèi)容映射成一個(gè)新的信號(hào),信號(hào)可以是任意類型诫欠。

flattenMap使用步驟:
1.傳入一個(gè)block涵卵,block類型是返回值RACStream,參數(shù)value
2.參數(shù)value就是源信號(hào)的內(nèi)容呕诉,拿到源信號(hào)的內(nèi)容做處理
3.包裝成RACReturnSignal信號(hào)缘厢,返回出去。

flattenMap底層實(shí)現(xiàn):
0.flattenMap內(nèi)部調(diào)用bind方法實(shí)現(xiàn)的,flattenMapblock的返回值甩挫,會(huì)作為bindbindBlock的返回值贴硫。
1.當(dāng)訂閱綁定信號(hào),就會(huì)生成bindBlock
2.當(dāng)源信號(hào)發(fā)送內(nèi)容英遭,就會(huì)調(diào)用bindBlock(value, *stop)
3.調(diào)用bindBlock间护,內(nèi)部就會(huì)調(diào)用flattenMap的blockflattenMapblock作用:就是把處理好的數(shù)據(jù)包裝成信號(hào)挖诸。
4.返回的信號(hào)最終會(huì)作為bindBlock中的返回信號(hào)汁尺,當(dāng)做bindBlock的返回信號(hào)。
5.訂閱bindBlock的返回信號(hào)多律,就會(huì)拿到綁定信號(hào)的訂閱者痴突,把處理完成的信號(hào)內(nèi)容發(fā)送出來(lái)。

- (void)testMapFlattenMap{
    [[self.textField.rac_textSignal filter:^BOOL(NSString * _Nullable value) {
        return YES;
    }] subscribeNext:^(NSString * _Nullable x) {
        NSLog(@"filter == %@",x);
    }];
    
    
    [[self.textField.rac_textSignal map:^id _Nullable(NSString * _Nullable value) {
        return nil;
    }] subscribeNext:^(id  _Nullable x) {
        NSLog(@"map == %@",x);
    }];

    [[self.textField.rac_textSignal flattenMap:^__kindof RACSignal * _Nullable(NSString * _Nullable value) {
        NSLog(@"%@",value);
        return [RACReturnSignal return:[NSString stringWithFormat:@"輸出:%@",value]];
    }] subscribeNext:^(id  _Nullable x) {
        NSLog(@"flattenMap == %@",x);
    }];
}

// 打印日志
2022-11-22 17:25:47.505881+0800 001---RAC初探[2341:63531] filter == 1
2022-11-22 17:25:47.506094+0800 001---RAC初探[2341:63531] map == (null)
2022-11-22 17:25:47.506318+0800 001---RAC初探[2341:63531] 1
2022-11-22 17:25:47.506493+0800 001---RAC初探[2341:63531] flattenMap == 輸出:1
信號(hào)過(guò)濾

filter:過(guò)濾信號(hào)狼荞,使用它可以獲取滿足條件的信號(hào)辽装。每次信號(hào)發(fā)出,會(huì)先執(zhí)行過(guò)濾條件判斷相味。

- (void)testFilter{
    RACSignal *signal = [self.textField.rac_textSignal filter:^BOOL(NSString * _Nullable value) {
        if (self.textField.text.length>6) {
            self.textField.text = [self.textField.text substringToIndex:6];
        }
        NSLog(@"value == %@",value);
        return value.length<6;
    }];
    
    [signal subscribeNext:^(id  _Nullable x) {
        self.textField.text = x;
        NSLog(@"x== %@",x);
    }];
}

// 當(dāng)textField輸入內(nèi)容長(zhǎng)度超過(guò)6個(gè)時(shí)拾积,[signal subscribeNext]就不會(huì)執(zhí)行

內(nèi)部調(diào)用filter過(guò)濾,忽略掉ignore的值

- (void)testIgnore{
    [[self.textField.rac_textSignal ignore:@"c"] subscribeNext:^(NSString * _Nullable x) {
        NSLog(@"%@",x);
    }];
}

distinctUntilChanged:當(dāng)上一次的值和當(dāng)前的值有明顯的變化就會(huì)發(fā)出信號(hào)丰涉,否則會(huì)被忽略掉拓巧;在開(kāi)發(fā)中,刷新UI經(jīng)常使用一死,只有兩次數(shù)據(jù)不一樣才需要刷新

- (void)testDistinctUntilChanged{
    RACSubject *subject = [RACSubject subject];
    [[subject distinctUntilChanged] subscribeNext:^(id x) {
        NSLog(@"%@", x);
    }];
    // 發(fā)送信號(hào)
    [subject sendNext:@1];
    [subject sendNext:@2];
    [subject sendNext:@2];
}

// 打印日志
2022-11-23 23:02:24.962120+0800 001---RAC初探[11912:536530] 1
2022-11-23 23:02:24.962358+0800 001---RAC初探[11912:536530] 2
信號(hào)合并

信號(hào)合并:將多個(gè)信號(hào)合并起來(lái)肛度,并且拿到各個(gè)信號(hào)的最新的值。必須每個(gè)合并的signal至少都有過(guò)一次sendNext摘符,才會(huì)觸發(fā)合并的信號(hào)贤斜。

底層實(shí)現(xiàn):
1.當(dāng)組合信號(hào)被訂閱,內(nèi)部會(huì)自動(dòng)訂閱signalA逛裤,signalB必須兩個(gè)信號(hào)都發(fā)出內(nèi)容瘩绒,才會(huì)被觸發(fā)。
2.并且把兩個(gè)信號(hào)組合成元組發(fā)出带族。

區(qū)別于zipWith zipWith兩個(gè)信號(hào)都要有記錄,如果記錄的信號(hào)觸發(fā)過(guò)了 就不在觸發(fā)锁荔;zipWith記錄每一次信號(hào),combineLatestWith記錄最后一次的信號(hào)蝙砌。

- (void)testCombineLatest{
    RACSignal *signalA = self.textField.rac_textSignal;
    RACSignal *signalB = [self.button  rac_signalForControlEvents:UIControlEventTouchUpInside];
    
    // 合并信號(hào),任何一個(gè)信號(hào)發(fā)送數(shù)據(jù)阳堕,都能監(jiān)聽(tīng)到.
    RACSignal *comSignal = [signalA combineLatestWith:signalB];
    [comSignal subscribeNext:^(id x) {
        NSLog(@"%@",x);
    }];
}

// 打印日志
2022-11-22 20:03:13.967697+0800 001---RAC初探[3482:124431] <RACTwoTuple: 0x600003449a20> (
    "",
    "<UIButton: 0x7f8b13f0d380; frame = (166 223; 46 256); opaque = NO; autoresize = RM+BM; layer = <CALayer: 0x60000366c660>>"
)
2022-11-22 20:03:19.526330+0800 001---RAC初探[3482:124431] <RACTwoTuple: 0x6000034509f0> (
    1,
    "<UIButton: 0x7f8b13f0d380; frame = (166 223; 46 256); opaque = NO; autoresize = RM+BM; layer = <CALayer: 0x60000366c660>>"
)

reduce聚合:用于信號(hào)發(fā)出的內(nèi)容是元組,把信號(hào)發(fā)出元組的值聚合成一個(gè)值择克。其中Aggregation(聚合關(guān)系)恬总、Composition(合成關(guān)系)屬于Association(關(guān)聯(lián)關(guān)系),是特殊的Association關(guān)聯(lián)關(guān)系肚邢。

可以延伸組合關(guān)系,聚合關(guān)系

  • 組合關(guān)系 A-B組合成了C C包含所有的A和B
  • 聚合關(guān)系 聚合關(guān)系是整體和個(gè)體的關(guān)系(是強(qiáng)的關(guān)聯(lián)關(guān)系) 公司與個(gè)人,但是個(gè)人不完全屬于公司

聚合: 常見(jiàn)的用法壹堰,(先組合再聚合)
reduce中的block簡(jiǎn)介:
reduceblcok中的參數(shù)拭卿,有多少信號(hào)組合,reduceblcok就有多少參數(shù)贱纠,每個(gè)參數(shù)就是之前信號(hào)發(fā)出的內(nèi)容
reduceblcok的返回值:聚合信號(hào)之后的內(nèi)容峻厚。
combineLatest:(id<NSFastEnumeration>)signals reduce:(id (^)())reduceBlock

- (void)testReduce{
    RACSignal *signalA = self.textField.rac_textSignal;
    RACSignal *signalB = [self.button  rac_signalForControlEvents:UIControlEventTouchUpInside];

    // 1.訂閱聚合信號(hào),每次有內(nèi)容發(fā)出谆焊,就會(huì)執(zhí)行reduceblcok惠桃,把信號(hào)內(nèi)容轉(zhuǎn)換成reduceblcok返回的值。
    RACSignal *reduceSignal = [RACSignal combineLatest:@[signalA,signalB] reduce:^(id value1, id value2){
        return [NSString stringWithFormat:@"reduce == %@ %@",value1,value2];
    }];
    
    [reduceSignal subscribeNext:^(id  _Nullable x) {
        NSLog(@"subscribeNext == %@",x);
    }];
}

merge:把多個(gè)信號(hào)合并成一個(gè)信號(hào)

- (void)testMerge{
    //創(chuàng)建多個(gè)信號(hào)
    RACSignal *signalA = self.textField.rac_textSignal;
    RACSignal *signalB = [self.button  rac_signalForControlEvents:UIControlEventTouchUpInside];
    
    // 合并信號(hào),任何一個(gè)信號(hào)發(fā)送數(shù)據(jù)辖试,都能監(jiān)聽(tīng)到.
    RACSignal *mergeSignal = [signalA merge:signalB];
    [mergeSignal subscribeNext:^(id x) {
        NSLog(@"x = %@",x);
    }];
}

// 打印日志
2022-11-22 22:23:13.389201+0800 001---RAC初探[5329:216279] x = 111
2022-11-22 22:24:12.004151+0800 001---RAC初探[5329:216279] x = <UIButton: 0x7f7f6be09180; frame = (166 223; 46 256); opaque = NO; autoresize = RM+BM; layer = <CALayer: 0x600002c96700>>

zipWith底層實(shí)現(xiàn):
1.定義壓縮信號(hào)辜王,內(nèi)部就會(huì)自動(dòng)訂閱signalAsignalB
2.每當(dāng)signalA或者signalB發(fā)出信號(hào)剃执,就會(huì)判斷signalA誓禁,signalB有沒(méi)有發(fā)出個(gè)信號(hào),有就會(huì)把最近發(fā)出的信號(hào)都包裝成元組發(fā)出肾档。

- (void)testZip{
    RACSignal *signalA = self.textField.rac_textSignal;
    RACSignal *signalB = [self.button  rac_signalForControlEvents:UIControlEventTouchUpInside];
    
    // 合并信號(hào),任何一個(gè)信號(hào)發(fā)送數(shù)據(jù),都能監(jiān)聽(tīng)到.
    RACSignal *zipSignal = [signalA zipWith:signalB];
    [zipSignal subscribeNext:^(id x) {
        NSLog(@"%@",x);
    }];
}
信號(hào)連接
- (void)testContact{
    RACSignal *signalA = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        [subscriber sendNext:@"Hello"];
        [subscriber sendCompleted];
        return nil;
    }];
    
    RACSignal *signalB = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        [subscriber sendNext:@"World"];
        [subscriber sendCompleted];
        return nil;
    }];
    
    RACSignal *contactSignal = [signalA concat:signalB];
    [contactSignal subscribeNext:^(id  _Nullable x) {
        NSLog(@"信號(hào)連接%@",x);
    }];
}

// 打印日志
2022-11-22 21:54:00.619302+0800 001---RAC初探[4556:186514] 信號(hào)連接Hello
2022-11-22 21:54:00.619527+0800 001---RAC初探[4556:186514] 信號(hào)連接World
- (void)testThen{
    [[[RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        [subscriber sendNext:@"Hello"];
        [subscriber sendCompleted];
        return nil;
    }] then:^RACSignal * _Nonnull{
        return [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
            [subscriber sendNext:@"World"];
            [subscriber sendCompleted];
            return nil;
        }];
    }] subscribeNext:^(id  _Nullable x) {
        NSLog(@"%@",x);
    }];
}

// 打印日志
2022-11-22 22:20:31.483147+0800 001---RAC初探[5254:213039] World

使用RAC中bind方法做處理辫继,在返回結(jié)果前拼接怒见。
bind方法參數(shù):需要傳入一個(gè)返回值是RACStreamBindBlockblock參數(shù)

  • RACStreamBindBlock是一個(gè)block類型,返回值是信號(hào)姑宽,參數(shù)(value,stop)遣耍,因此參數(shù)的block返回值也是一個(gè)block
    RACStreamBindBlock:
  • 參數(shù)一(value):表示接收到信號(hào)的原始值炮车,還沒(méi)做處理
  • 參數(shù)二(stop):用來(lái)控制綁定Block舵变,如果stop = yes,那么就會(huì)結(jié)束綁定。
  • 返回值:信號(hào)瘦穆,做好處理纪隙,在通過(guò)這個(gè)信號(hào)返回出去,一般使用RACReturnSignal,需要手動(dòng)導(dǎo)入頭文件RACReturnSignal.h扛或。

bind方法使用步驟:
1.傳入一個(gè)返回值RACStreamBindBlock的block绵咱。
2.描述一個(gè)RACStreamBindBlock類型的bindBlock作為block的返回值。
3.描述一個(gè)返回結(jié)果的信號(hào)熙兔,作為bindBlock的返回值悲伶。
注意:在bindBlock中做信號(hào)結(jié)果的處理。

底層實(shí)現(xiàn):
1.源信號(hào)調(diào)用bind,會(huì)重新創(chuàng)建一個(gè)綁定信號(hào)住涉。
2.當(dāng)綁定信號(hào)被訂閱麸锉,就會(huì)調(diào)用綁定信號(hào)中的didSubscribe,生成一個(gè)bindingBlock舆声。
3.當(dāng)源信號(hào)有內(nèi)容發(fā)出花沉,就會(huì)把內(nèi)容傳遞到bindingBlock處理,調(diào)用bindingBlock(value,stop)
4.調(diào)用bindingBlock(value,stop),會(huì)返回一個(gè)內(nèi)容處理完成的信號(hào)(RACReturnSignal)主穗。
5.訂閱RACReturnSignal泻拦,就會(huì)拿到綁定信號(hào)的訂閱者,把處理完成的信號(hào)內(nèi)容發(fā)送出來(lái)忽媒。
注意:不同訂閱者争拐,保存不同的nextBlock,看源碼的時(shí)候晦雨,一定要看清楚訂閱者是哪個(gè)架曹。這里需要手動(dòng)導(dǎo)入#import <ReactiveCocoa/RACReturnSignal.h>,才能使用RACReturnSignal闹瞧。

- (void)testBind{
    [[self.textField.rac_textSignal bind:^RACSignalBindBlock _Nonnull{
        return ^RACSignal * (id _Nullable value, BOOL *stop) {
            return [RACReturnSignal return:[NSString stringWithFormat:@"輸出:%@",value]];
        };
    }] subscribeNext:^(id  _Nullable x) {
        NSLog(@"subscribeNext == %@",x);
    }];
}

// 打印日志
2022-11-23 23:20:25.583676+0800 001---RAC初探[12013:542540] subscribeNext == 輸出:
2022-11-23 23:20:26.994845+0800 001---RAC初探[12013:542540] subscribeNext == 輸出:1
信號(hào)操作時(shí)間
- (void)timeOut{
    RACSignal *signal = [[RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
        return nil;
    }] timeout:1 onScheduler:[RACScheduler currentScheduler]];
    
    [signal subscribeNext:^(id  _Nullable x) {
        NSLog(@"x = %@",x);
    } error:^(NSError * _Nullable error) {
        NSLog(@"error = %@",error);
    }];
}

// 打印日志
2022-11-22 21:58:01.528503+0800 001---RAC初探[4654:190636] error = Error Domain=RACSignalErrorDomain Code=1 "(null)"
信號(hào)取值

take:可以屏蔽一些值,取前面幾個(gè)值---這里take為2 則只拿到前兩個(gè)值

- (void)take {
    RACSubject *subject = [RACSubject subject];
    [[subject take:2] subscribeNext:^(id x) {
        NSLog(@"%@", x);
    }];
    // 發(fā)送信號(hào)
    [subject sendNext:@1];
    [subject sendNext:@2];
    [subject sendNext:@3];
}

// 打印日志
2022-11-22 22:01:54.780891+0800 001---RAC初探[4714:193798] 1
2022-11-22 22:01:54.781186+0800 001---RAC初探[4714:193798] 2

takeLast:take的用法一樣绑雄,不過(guò)他取的是最后的幾個(gè)值,如下奥邮,則取的是最后兩個(gè)值
注意點(diǎn):takeLast 一定要調(diào)用sendCompleted万牺,告訴他發(fā)送完成了,這樣才能取到最后的幾個(gè)值

- (void)takeLast {
    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];
}

// 打印日志
2022-11-22 22:03:44.288135+0800 001---RAC初探[4765:195850] 2
2022-11-22 22:03:44.288369+0800 001---RAC初探[4765:195850] 3

takeUntil:---給takeUntil傳的是哪個(gè)信號(hào)洽腺,那么當(dāng)這個(gè)信號(hào)發(fā)送信號(hào)或sendCompleted脚粟,就不能再接受源信號(hào)的內(nèi)容了。

- (void)takeUntil {
    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];
}

// 打印日志
2022-11-22 22:06:59.819817+0800 001---RAC初探[4868:199064] 1
2022-11-22 22:06:59.820111+0800 001---RAC初探[4868:199064] 2
2022-11-22 22:06:59.820271+0800 001---RAC初探[4868:199064] 4
信號(hào)跳過(guò)
- (void)testSkip{
    // 表示輸入第一次蘸朋,不會(huì)被監(jiān)聽(tīng)到核无,跳過(guò)第一次發(fā)出的信號(hào)
    [[self.textField.rac_textSignal skip:1] subscribeNext:^(id x) {
        NSLog(@"%@",x);
    }];
}
獲取信號(hào)中的信號(hào)
- (void)testSwitchToLatest {
    RACSubject *signalOfSignals = [RACSubject subject];
    RACSubject *signal = [RACSubject subject];
    // 獲取信號(hào)中信號(hào)最近發(fā)出信號(hào),訂閱最近發(fā)出的信號(hào)藕坯。
    // 注意switchToLatest:只能用于信號(hào)中的信號(hào)
    [signalOfSignals.switchToLatest subscribeNext:^(id x) { NSLog(@"%@",x);
    }];
    [signalOfSignals sendNext:signal];
    [signal sendNext:@1];
}

// 打印日志
2022-11-22 22:10:45.425025+0800 001---RAC初探[4976:203305] 1
信號(hào)錯(cuò)誤重試

retry重試 :只要失敗团南,就會(huì)重新執(zhí)行創(chuàng)建信號(hào)中的block,直到成功.

- (void)retry{
    //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) {
    
        }];
}

// 打印日志
2022-11-22 22:15:24.167254+0800 001---RAC初探[5075:207315] 接收到錯(cuò)誤
2022-11-22 22:15:24.245548+0800 001---RAC初探[5075:207315] 接收到錯(cuò)誤
2022-11-22 22:15:24.245849+0800 001---RAC初探[5075:207315] 接收到錯(cuò)誤
2022-11-22 22:15:24.246074+0800 001---RAC初探[5075:207315] 接收到錯(cuò)誤
2022-11-22 22:15:24.246324+0800 001---RAC初探[5075:207315] 接收到錯(cuò)誤
2022-11-22 22:15:24.246580+0800 001---RAC初探[5075:207315] 接收到錯(cuò)誤
2022-11-22 22:15:24.246878+0800 001---RAC初探[5075:207315] 接收到錯(cuò)誤
2022-11-22 22:15:24.247095+0800 001---RAC初探[5075:207315] 接收到錯(cuò)誤
2022-11-22 22:15:24.247306+0800 001---RAC初探[5075:207315] 接收到錯(cuò)誤
2022-11-22 22:15:24.247569+0800 001---RAC初探[5075:207315] 接收到錯(cuò)誤
2022-11-22 22:15:24.248111+0800 001---RAC初探[5075:207315] 1

replay重放:當(dāng)一個(gè)信號(hào)被多次訂閱,反復(fù)播放內(nèi)容

- (void)replay{
    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);
    }];
}

// 打印日志
2022-11-22 22:16:58.438272+0800 001---RAC初探[5139:209222] 第一個(gè)訂閱者1
2022-11-22 22:16:58.438463+0800 001---RAC初探[5139:209222] 第一個(gè)訂閱者2
2022-11-22 22:16:58.439071+0800 001---RAC初探[5139:209222] 第二個(gè)訂閱者1
2022-11-22 22:16:58.439237+0800 001---RAC初探[5139:209222] 第二個(gè)訂閱者2
信號(hào)生命周期
信號(hào)生命周期

RACSignal使用步驟:

  • 創(chuàng)建信號(hào) + (RACSignal *)createSignal:(RACDisposable * (^)(id<RACSubscriber> subscriber))didSubscribe
  • 訂閱信號(hào)才會(huì)激活信號(hào)- (RACDisposable *)subscribeNext:(void (^)(id x))nextBlock
  • 發(fā)送信號(hào)- (void)sendNext:(id)value
- (void)racBase{
    // 創(chuàng)建信號(hào)
    RACSignal *signal = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        // block調(diào)用時(shí)刻:每當(dāng)有訂閱者訂閱信號(hào)炼彪,就會(huì)調(diào)用block吐根。
        [subscriber sendNext:@"Hello World"];
        // 如果不在發(fā)送數(shù)據(jù),最好發(fā)送信號(hào)完成霹购,內(nèi)部會(huì)自動(dòng)調(diào)用[RACDisposable disposable]取消訂閱信號(hào)佑惠。
        //        [subscriber sendCompleted];
        NSLog(@"subscriber == %@",subscriber);
        
        RACDisposable *disposable = [RACDisposable disposableWithBlock:^{
            // 銷毀信號(hào)
            // block調(diào)用時(shí)刻:當(dāng)信號(hào)發(fā)送完成或者發(fā)送錯(cuò)誤,就會(huì)自動(dòng)執(zhí)行這個(gè)block,取消訂閱信號(hào)齐疙。
            // 執(zhí)行完Block后膜楷,當(dāng)前信號(hào)就不在被訂閱了。
            NSLog(@"開(kāi)始銷毀");
        }];
        return disposable;
    }];
    
    // 訂閱信號(hào),才會(huì)激活信號(hào).
    [signal subscribeNext:^(id  _Nullable x) {
        NSLog(@"x == %@",x);
    }];
}

2022-11-22 20:35:07.838619+0800 001---RAC初探[3821:146953] x == Hello World
2022-11-22 20:35:07.838851+0800 001---RAC初探[3821:146953] subscriber == <RACPassthroughSubscriber: 0x600002d90480>
2022-11-22 20:35:07.839402+0800 001---RAC初探[3821:146953] 開(kāi)始銷毀
RAC信號(hào)創(chuàng)建-訂閱-發(fā)送流程

由于RAC在底層封裝了UIControl贞奋,就可以在UI中隨意使用赌厅。

RACSignal底層實(shí)現(xiàn):

  • 創(chuàng)建信號(hào),首先把didSubscribe保存到信號(hào)中轿塔,還不會(huì)觸發(fā)特愿。
  • 當(dāng)信號(hào)被訂閱仲墨,也就是調(diào)用signalsubscribeNext:nextBlock
    subscribeNext內(nèi)部會(huì)創(chuàng)建訂閱者subscriber,并且把nextBlock保存到subscriber中揍障。
    subscribeNext內(nèi)部會(huì)調(diào)用siganldidSubscribe
  • siganldidSubscribe中調(diào)用[subscriber sendNext:@1];
    sendNext底層其實(shí)就是執(zhí)行subscribernextBlock
信號(hào)銷毀
@property (nonatomic, strong) RACDisposable *dispose;

- (void)testTimer{
    self.dispose = [[RACSignal interval:1 onScheduler:[RACScheduler scheduler]] subscribeNext:^(NSDate * _Nullable x) {
        NSLog(@"%@",[NSThread currentThread]);
    }];
}

- (void)touchesBegan:(NSSet<UITouch *> *)touches withEvent:(UIEvent *)event{
    [self.dispose dispose];
}

// 定時(shí)器每隔1秒打印當(dāng)前線程目养,點(diǎn)擊屏幕使信號(hào)銷毀,就能停止定時(shí)器
// 打印日志
2022-11-23 23:26:02.584826+0800 001---RAC初探[12139:553576] <NSThread: 0x600001479fc0>{number = 5, name = (null)}
2022-11-23 23:26:03.584991+0800 001---RAC初探[12139:553573] <NSThread: 0x600001408940>{number = 7, name = (null)}
最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
  • 序言:七十年代末毒嫡,一起剝皮案震驚了整個(gè)濱河市癌蚁,隨后出現(xiàn)的幾起案子,更是在濱河造成了極大的恐慌兜畸,老刑警劉巖努释,帶你破解...
    沈念sama閱讀 216,372評(píng)論 6 498
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件,死亡現(xiàn)場(chǎng)離奇詭異咬摇,居然都是意外死亡伐蒂,警方通過(guò)查閱死者的電腦和手機(jī),發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 92,368評(píng)論 3 392
  • 文/潘曉璐 我一進(jìn)店門肛鹏,熙熙樓的掌柜王于貴愁眉苦臉地迎上來(lái)逸邦,“玉大人,你說(shuō)我怎么就攤上這事龄坪≌汛疲” “怎么了?”我有些...
    開(kāi)封第一講書人閱讀 162,415評(píng)論 0 353
  • 文/不壞的土叔 我叫張陵健田,是天一觀的道長(zhǎng)。 經(jīng)常有香客問(wèn)我佛纫,道長(zhǎng)妓局,這世上最難降的妖魔是什么? 我笑而不...
    開(kāi)封第一講書人閱讀 58,157評(píng)論 1 292
  • 正文 為了忘掉前任呈宇,我火速辦了婚禮好爬,結(jié)果婚禮上,老公的妹妹穿的比我還像新娘甥啄。我一直安慰自己存炮,他們只是感情好,可當(dāng)我...
    茶點(diǎn)故事閱讀 67,171評(píng)論 6 388
  • 文/花漫 我一把揭開(kāi)白布蜈漓。 她就那樣靜靜地躺著穆桂,像睡著了一般。 火紅的嫁衣襯著肌膚如雪融虽。 梳的紋絲不亂的頭發(fā)上享完,一...
    開(kāi)封第一講書人閱讀 51,125評(píng)論 1 297
  • 那天,我揣著相機(jī)與錄音有额,去河邊找鬼般又。 笑死彼绷,一個(gè)胖子當(dāng)著我的面吹牛,可吹牛的內(nèi)容都是我干的茴迁。 我是一名探鬼主播寄悯,決...
    沈念sama閱讀 40,028評(píng)論 3 417
  • 文/蒼蘭香墨 我猛地睜開(kāi)眼,長(zhǎng)吁一口氣:“原來(lái)是場(chǎng)噩夢(mèng)啊……” “哼堕义!你這毒婦竟也來(lái)了猜旬?” 一聲冷哼從身側(cè)響起,我...
    開(kāi)封第一講書人閱讀 38,887評(píng)論 0 274
  • 序言:老撾萬(wàn)榮一對(duì)情侶失蹤胳螟,失蹤者是張志新(化名)和其女友劉穎昔馋,沒(méi)想到半個(gè)月后,有當(dāng)?shù)厝嗽跇?shù)林里發(fā)現(xiàn)了一具尸體糖耸,經(jīng)...
    沈念sama閱讀 45,310評(píng)論 1 310
  • 正文 獨(dú)居荒郊野嶺守林人離奇死亡秘遏,尸身上長(zhǎng)有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 37,533評(píng)論 2 332
  • 正文 我和宋清朗相戀三年,在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了嘉竟。 大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片邦危。...
    茶點(diǎn)故事閱讀 39,690評(píng)論 1 348
  • 序言:一個(gè)原本活蹦亂跳的男人離奇死亡,死狀恐怖舍扰,靈堂內(nèi)的尸體忽然破棺而出倦蚪,到底是詐尸還是另有隱情,我是刑警寧澤边苹,帶...
    沈念sama閱讀 35,411評(píng)論 5 343
  • 正文 年R本政府宣布陵且,位于F島的核電站,受9級(jí)特大地震影響个束,放射性物質(zhì)發(fā)生泄漏慕购。R本人自食惡果不足惜,卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 41,004評(píng)論 3 325
  • 文/蒙蒙 一茬底、第九天 我趴在偏房一處隱蔽的房頂上張望沪悲。 院中可真熱鬧,春花似錦阱表、人聲如沸殿如。這莊子的主人今日做“春日...
    開(kāi)封第一講書人閱讀 31,659評(píng)論 0 22
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽(yáng)涉馁。三九已至,卻和暖如春烂叔,著一層夾襖步出監(jiān)牢的瞬間谨胞,已是汗流浹背。 一陣腳步聲響...
    開(kāi)封第一講書人閱讀 32,812評(píng)論 1 268
  • 我被黑心中介騙來(lái)泰國(guó)打工蒜鸡, 沒(méi)想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留胯努,地道東北人牢裳。 一個(gè)月前我還...
    沈念sama閱讀 47,693評(píng)論 2 368
  • 正文 我出身青樓,卻偏偏與公主長(zhǎng)得像叶沛,于是被迫代替她去往敵國(guó)和親蒲讯。 傳聞我的和親對(duì)象是個(gè)殘疾皇子,可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 44,577評(píng)論 2 353

推薦閱讀更多精彩內(nèi)容

  • RAC在iOS的實(shí)際開(kāi)發(fā)中確實(shí)是一件有力的武器灰署,此文將從以下幾方面講解 RACSignal RACSubject ...
    4b5cb36a2ee2閱讀 900評(píng)論 0 0
  • ReactiveCocoa使用個(gè)人總結(jié) ReactiveCocoa簡(jiǎn)介 ReactiveCocoa(簡(jiǎn)稱RAC)是...
    考槃在澗閱讀 265評(píng)論 0 1
  • RAC使用測(cè)試Demo下載:github.com/FuWees/WPRACTestDemo 1.ReactiveC...
    FuWees閱讀 6,368評(píng)論 3 10
  • 1判帮、RACSignal // 只要訂閱者調(diào)用sendNext,就會(huì)執(zhí)行nextBlock // 只要訂閱RACD...
    路上撿只貓閱讀 865評(píng)論 0 1
  • 前言 ? RAC,全稱是ReactiveCocoa溉箕,是函數(shù)式編程和響應(yīng)式編程的結(jié)合晦墙。函數(shù)式編程的第一個(gè)特點(diǎn)就是可以...
    xxxxxxxx_123閱讀 860評(píng)論 0 1