RAC+MVVM在實(shí)際開(kāi)發(fā)中的常用用法
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];
RACSubject
RACSubject 在使用中我們可以完全代替代理，代碼簡(jiǎn)介方法瑟幕。具體代碼請(qǐng)看demo中的RACSubject磕蒲。
// 創(chuàng)建信號(hào)
RACSubject *subject = [RACSubject subject];
// 訂閱信號(hào)
[subject subscribeNext:^(id x) {
// block:當(dāng)有數(shù)據(jù)發(fā)出的時(shí)候就會(huì)調(diào)用
// block:處理數(shù)據(jù)
NSLog(@"%@",x);
}];
// 發(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
使用場(chǎng)景---： 可以快速高效的遍歷數(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宏：專門用來(lái)解析元組
// 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十偶，來(lái)實(shí)現(xiàn)。代碼示例如下
// 普通寫法, 這樣的缺點(diǎn)是：沒(méi)訂閱一次信號(hào)就得重新創(chuàng)建并發(fā)送請(qǐng)求园细，這樣很不友好
RACSignal *signal = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
// didSubscribeblock中的代碼都統(tǒng)稱為副作用惦积。
// 發(fā)送請(qǐng)求---比如afn
NSLog(@"發(fā)送請(qǐng)求啦");
// 發(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珊肃，無(wú)論有多少個(gè)訂閱者荣刑，無(wú)論訂閱多少次馅笙，我只發(fā)送一個(gè)伦乔。
// 1.發(fā)送請(qǐng)求，用一個(gè)信號(hào)內(nèi)包裝董习，不管有多少個(gè)訂閱者烈和，只想發(fā)一次請(qǐng)求
RACSignal *signal = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
// 發(fā)送請(qǐng)求
NSLog(@"發(fā)送請(qǐng)求啦");
// 發(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í)行過(guò)程疯暑，比如看事件有沒(méi)有執(zhí)行完畢
- 使用場(chǎng)景：監(jiān)聽(tīng)按鈕點(diǎn)擊，網(wǎng)絡(luò)請(qǐng)求
// 普通做法
// 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)來(lái)的參數(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)來(lái)的參數(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)聽(tīng)事件有沒(méi)有完成
//注意：當(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)聽(tīng)事件有沒(méi)有完成
[command.executing subscribeNext:^(id x) {
if ([x boolValue] == YES) { // 正在執(zhí)行
NSLog(@"當(dāng)前正在執(zhí)行%@", x);
}else {
// 執(zhí)行完成/沒(méi)有執(zhí)行
NSLog(@"執(zhí)行完成/沒(méi)有執(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)聽(tīng)某個(gè)對(duì)象的某個(gè)屬性改變
* 返回的是一個(gè)信號(hào),對(duì)象的某個(gè)屬性改變的信號(hào)
*/
[RACObserve(self.view, center) subscribeNext:^(id x) {
NSLog(@"%@", x);
}];
//例 textField輸入的值賦值給label丹弱，監(jiān)聽(tīng)label文字改變,
RAC(self.label, text) = self.textField.rac_textSignal;
[RACObserve(self.label, text) subscribeNext:^(id x) {
NSLog(@"====label的文字變了");
}];
/**
* 循環(huán)引用問(wèn)題
*/
@weakify(self)
RACSignal *signal = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
@strongify(self)
NSLog(@"%@",self.view);
return nil;
}];
_signal = signal;
使用 @weakify(self)和@strongify(self)來(lái)避免循環(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ì)來(lái)到這個(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ì)來(lái)到30行的block。在這個(gè)block里我們可以對(duì)數(shù)據(jù)進(jìn)行一些操作济赎，那么35行打印的value和訂閱綁定信號(hào)后的value就會(huì)變了鉴逞。變成什么樣隨你喜歡嘍。
RAC-過(guò)濾
有時(shí)候我們想要過(guò)濾一些信號(hào)司训，這時(shí)候我們便可以用RAC的過(guò)濾方法构捡。過(guò)濾方法有好多種，如下代碼壳猜，從不同情況下進(jìn)行了分析勾徽。
- 跳躍 ： 如下，skip傳入2 跳過(guò)前面兩個(gè)值
- 實(shí)際用處： 在實(shí)際開(kāi)發(fā)中比如 后臺(tái)返回的數(shù)據(jù)前面幾個(gè)沒(méi)用统扳，我們想跳躍過(guò)去喘帚，便可以用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的用法一樣咒钟，不過(guò)他取的是最后的幾個(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];
- 一般和文本框一起用级乍，添加過(guò)濾條件
- 只有當(dāng)文本框的內(nèi)容長(zhǎng)度大于5，才獲取文本框里的內(nèi)容
[[self.textField.rac_textSignal filter:^BOOL(id value) {
// value 源信號(hào)的內(nèi)容
return [value length] > 5;
// 返回值 就是過(guò)濾條件帚湘。只有滿足這個(gè)條件才能獲取到內(nèi)容
}] subscribeNext:^(id x) {
NSLog(@"%@", x);
}];
RAC-映射
RAC的映射在實(shí)際開(kāi)發(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)用來(lái)包裝成修改內(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--------也是開(kāi)發(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),使用場(chǎng)景—-：比如-當(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;
}
- 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事件
- (void)zipWith {
// 創(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è)請(qǐng)求的時(shí)候徘层，要等所有請(qǐng)求完成才更新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ā)送的順序無(wú)關(guān)趣效，而是跟壓縮的順序有關(guān)[signalA zipWith:signalB]---先是A后是B
[signalA sendNext:@1];
[signalB sendNext:@2];
}
- 任何一個(gè)信號(hào)請(qǐng)求完成都會(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ò)請(qǐng)求但是過(guò)濾掉數(shù)據(jù)，然后進(jìn)行下部分的英支，拿到下部分?jǐn)?shù)據(jù)
- (void)then {
// 創(chuàng)建信號(hào)A
RACSignal *signalA = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
// 發(fā)送請(qǐng)求
NSLog(@"----發(fā)送上部分請(qǐng)求---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ā)送請(qǐng)求
NSLog(@"--發(fā)送下部分請(qǐng)求--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ā)送請(qǐng)求
// NSLog(@"----發(fā)送上部分請(qǐng)求---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ā)送請(qǐng)求
// NSLog(@"--發(fā)送下部分請(qǐng)求--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);
}];
}
