ReactionCocoa

1.ReactiveCocoa簡(jiǎn)介

ReactiveCocoa(簡(jiǎn)稱(chēng)為RAC),是由Github開(kāi)源的一個(gè)應(yīng)用于iOS和OS開(kāi)發(fā)的新框架,Cocoa是蘋(píng)果整套框架的簡(jiǎn)稱(chēng),因此很多蘋(píng)果框架喜歡以Cocoa結(jié)尾。

2.ReactiveCocoa作用

在我們iOS開(kāi)發(fā)過(guò)程中,經(jīng)常會(huì)響應(yīng)某些事件來(lái)處理某些業(yè)務(wù)邏輯,例如按鈕的點(diǎn)擊,上下拉刷新,網(wǎng)絡(luò)請(qǐng)求,屬性的變化(通過(guò)KVO)或者用戶(hù)位置的變化(通過(guò)CoreLocation)。但是這些事件都用不同的方式來(lái)處理,比如action、delegate、KVO、callback等。

其實(shí)這些事件,都可以通過(guò)RAC處理,ReactiveCocoa為事件提供了很多處理方法,而且利用RAC處理事件很方便,可以把要處理的事情,和監(jiān)聽(tīng)的事情的代碼放在一起,這樣非常方便我們管理,就不需要跳到對(duì)應(yīng)的方法里。非常符合我們開(kāi)發(fā)中高聚合,低耦合的思想。

3.編程思想

在開(kāi)發(fā)中我們也不能太依賴(lài)于某個(gè)框架,否則這個(gè)框架不更新了,導(dǎo)致項(xiàng)目后期沒(méi)辦法維護(hù),比如之前Facebook提供的Three20框架,在當(dāng)時(shí)也是神器,但是后來(lái)不更新了,也就沒(méi)什么人用了。因此我感覺(jué)學(xué)習(xí)一個(gè)框架,還是有必要了解它的編程思想。

先簡(jiǎn)單介紹下目前咱們已知的編程思想。

3.1 面向過(guò)程:處理事情以過(guò)程為核心,一步一步的實(shí)現(xiàn)。

3.2 面向?qū)ο螅喝f(wàn)物皆對(duì)象

3.3 鏈?zhǔn)骄幊趟枷耄菏菍⒍鄠€(gè)操作(多行代碼)通過(guò)點(diǎn)號(hào)(.)鏈接在一起成為一句代碼,使代碼可讀性好。a(1).b(2).c(3)

* 鏈?zhǔn)骄幊烫攸c(diǎn):方法的返回值是block,block必須有返回值(本身對(duì)象),block參數(shù)(需要操作的值)

* 代表:masonry框架。

* 模仿masonry,寫(xiě)一個(gè)加法計(jì)算器,練習(xí)鏈?zhǔn)骄幊趟枷搿?/p>

4.ReactiveCocoa編程思想

ReactiveCocoa結(jié)合了幾種編程風(fēng)格:

函數(shù)式編程(Functional Programming)

響應(yīng)式編程(Reactive Programming)

所以,你可能聽(tīng)說(shuō)過(guò)ReactiveCocoa被描述為函數(shù)響應(yīng)式編程(FRP)框架。

以后使用RAC解決問(wèn)題,就不需要考慮調(diào)用順序,直接考慮結(jié)果,把每一次操作都寫(xiě)成一系列嵌套的方法中,使代碼高聚合,方便管理。

5.如何導(dǎo)入ReactiveCocoa框架

通常都會(huì)使用CocoaPods(用于管理第三方框架的插件)幫助我們導(dǎo)入。

PS:CocoaPods教程

注意:

* podfile如果只描述pod 'ReactiveCocoa', '~> 4.0.2-alpha-1',會(huì)導(dǎo)入不成功。

* Snip20150926_1.png

* 報(bào)錯(cuò)提示信息

Snip20150926_2.png

* 需要在podfile加上use_frameworks,重新pod install 才能導(dǎo)入成功。

Snip20150926_3.png

6.ReactiveCocoa常見(jiàn)類(lèi)。

學(xué)習(xí)框架首要之處:個(gè)人認(rèn)為先要搞清楚框架中常用的類(lèi),在RAC中最核心的類(lèi)RACSiganl,搞定這個(gè)類(lèi)就能用ReactiveCocoa開(kāi)發(fā)了。

6.1RACSiganl:信號(hào)類(lèi),一般表示將來(lái)有數(shù)據(jù)傳遞,只要有數(shù)據(jù)改變,信號(hào)內(nèi)部接收到數(shù)據(jù),就會(huì)馬上發(fā)出數(shù)據(jù)。

注意:

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

* 默認(rèn)一個(gè)信號(hào)都是冷信號(hào),也就是值改變了,也不會(huì)觸發(fā),只有訂閱了這個(gè)信號(hào),這個(gè)信號(hào)才會(huì)變?yōu)闊嵝盘?hào),值改變了才會(huì)觸發(fā)。

* 如何訂閱信號(hào):調(diào)用信號(hào)RACSignal的subscribeNext就能訂閱。

* RACSiganl簡(jiǎn)單使用:

? ?// RACSignal使用步驟:

? ?// 1.創(chuàng)建信號(hào) + (RACSignal *)createSignal:(RACDisposable * (^)(id subscriber))didSubscribe

? ?// 2.訂閱信號(hào),才會(huì)激活信號(hào). - (RACDisposable *)subscribeNext:(void (^)(id x))nextBlock

? ?// 3.發(fā)送信號(hào) - (void)sendNext:(id)value

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

? ?// 1.創(chuàng)建信號(hào),首先把didSubscribe保存到信號(hào)中,還不會(huì)觸發(fā)。

? ?// 2.當(dāng)信號(hào)被訂閱,也就是調(diào)用signal的subscribeNext:nextBlock

? ?// 2.2 subscribeNext內(nèi)部會(huì)創(chuàng)建訂閱者subscriber,并且把nextBlock保存到subscriber中。

? ?// 2.1 subscribeNext內(nèi)部會(huì)調(diào)用siganl的didSubscribe

? ?// 3.siganl的didSubscribe中調(diào)用[subscriber sendNext:@1];

? ?// 3.1 sendNext底層其實(shí)就是執(zhí)行subscriber的nextBlock

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

? ?RACSignal *siganl = [RACSignal createSignal:^RACDisposable *(id 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]取消訂閱信號(hào)。

? ? ? ?[subscriber sendCompleted];

? ? ? ?return [RACDisposable disposableWithBlock:^{

? ? ? ? ? ?// 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(@"信號(hào)被銷(xiāo)毀");

? ? ? ?}];

? ?}];

? ?// 3.訂閱信號(hào),才會(huì)激活信號(hào).

? ?[siganl subscribeNext:^(id x) {

? ? ? ?// block調(diào)用時(shí)刻:每當(dāng)有信號(hào)發(fā)出數(shù)據(jù),就會(huì)調(diào)用block.

? ? ? ?NSLog(@"接收到數(shù)據(jù):%@",x);

? ?}];

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

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

* 使用場(chǎng)景:不想監(jiān)聽(tīng)某個(gè)信號(hào)時(shí),可以通過(guò)它主動(dòng)取消訂閱信號(hào)。

6.4 RACSubject:RACSubject:信號(hào)提供者,自己可以充當(dāng)信號(hào),又能發(fā)送信號(hào)。

* 使用場(chǎng)景:通常用來(lái)代替代理,有了它,就不必要定義代理了。

6.5 RACReplaySubject:重復(fù)提供信號(hào)者,RACSubject的子類(lèi)。

* 使用場(chǎng)景:如果一個(gè)信號(hào)每被訂閱一次,就需要把之前的值重復(fù)發(fā)送一遍,使用重復(fù)提供信號(hào)類(lèi)。

* RACSubject和RACReplaySubject簡(jiǎn)單使用:

// RACSubject使用步驟

? ?// 1.創(chuàng)建信號(hào) [RACSubject subject],跟RACSiganl不一樣,創(chuàng)建信號(hào)時(shí)沒(méi)有block。

? ?// 2.訂閱信號(hào) - (RACDisposable *)subscribeNext:(void (^)(id x))nextBlock

? ?// 3.發(fā)送信號(hào) sendNext:(id)value

? ?// RACSubject:底層實(shí)現(xiàn)和RACSignal不一樣。

? ?// 1.調(diào)用subscribeNext訂閱信號(hào),只是把訂閱者保存起來(lái),并且訂閱者的nextBlock已經(jīng)賦值了。

? ?// 2.調(diào)用sendNext發(fā)送信號(hào),遍歷剛剛保存的所有訂閱者,一個(gè)一個(gè)調(diào)用訂閱者的nextBlock。

? ?// 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"];

? ?// RACReplaySubject使用步驟:

? ?// 1.創(chuàng)建信號(hào) [RACSubject subject],跟RACSiganl不一樣,創(chuàng)建信號(hào)時(shí)沒(méi)有block。

? ?// 2.可以先訂閱信號(hào),也可以先發(fā)送信號(hào)。

? ?// 2.1 訂閱信號(hào) - (RACDisposable *)subscribeNext:(void (^)(id x))nextBlock

? ?// 2.2 發(fā)送信號(hào) sendNext:(id)value

? ?// RACReplaySubject:底層實(shí)現(xiàn)和RACSubject不一樣。

? ?// 1.調(diào)用sendNext發(fā)送信號(hào),把值保存起來(lái),然后遍歷剛剛保存的所有訂閱者,一個(gè)一個(gè)調(diào)用訂閱者的nextBlock。

? ?// 2.調(diào)用subscribeNext訂閱信號(hào),遍歷保存的所有值,一個(gè)一個(gè)調(diào)用訂閱者的nextBlock

? ?// 如果想當(dāng)一個(gè)信號(hào)被訂閱,就重復(fù)播放之前所有值,需要先發(fā)送信號(hào),在訂閱信號(hào)。

? ?// 也就是先保存值,在訂閱值。

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

? ?RACReplaySubject *replaySubject = [RACReplaySubject subject];

? ?// 2.發(fā)送信號(hào)

? ?[replaySubject sendNext:@1];

? ?[replaySubject sendNext:@2];

? ?// 3.訂閱信號(hào)

? ?[replaySubject subscribeNext:^(id x) {

? ? ? ?NSLog(@"第一個(gè)訂閱者接收到的數(shù)據(jù)%@",x);

? ?}];

? ?// 訂閱信號(hào)

? ?[replaySubject subscribeNext:^(id x) {

? ? ? ?NSLog(@"第二個(gè)訂閱者接收到的數(shù)據(jù)%@",x);

? ?}];

* RACSubject替換代理

? ?// 需求:

? ?// 1.給當(dāng)前控制器添加一個(gè)按鈕,modal到另一個(gè)控制器界面

? ?// 2.另一個(gè)控制器view中有個(gè)按鈕,點(diǎn)擊按鈕,通知當(dāng)前控制器

步驟一:在第二個(gè)控制器.h,添加一個(gè)RACSubject代替代理。

@interface TwoViewController : UIViewController

@property (nonatomic, strong) RACSubject *delegateSignal;

@end

步驟二:監(jiān)聽(tīng)第二個(gè)控制器按鈕點(diǎn)擊

@implementation TwoViewController

- (IBAction)notice:(id)sender {

? ?// 通知第一個(gè)控制器,告訴它,按鈕被點(diǎn)了

? ? // 通知代理

? ? // 判斷代理信號(hào)是否有值

? ?if (self.delegateSignal) {

? ? ? ?// 有值,才需要通知

? ? ? ?[self.delegateSignal sendNext:nil];

? ?}

}

@end

步驟三:在第一個(gè)控制器中,監(jiān)聽(tīng)跳轉(zhuǎn)按鈕,給第二個(gè)控制器的代理信號(hào)賦值,并且監(jiān)聽(tīng).

@implementation OneViewController

- (IBAction)btnClick:(id)sender {

? ?// 創(chuàng)建第二個(gè)控制器

? ?TwoViewController *twoVc = [[TwoViewController alloc] init];

? ?// 設(shè)置代理信號(hào)

? ?twoVc.delegateSignal = [RACSubject subject];

? ?// 訂閱代理信號(hào)

? ?[twoVc.delegateSignal subscribeNext:^(id x) {

? ? ? ?NSLog(@"點(diǎn)擊了通知按鈕");

? ?}];

? ?// 跳轉(zhuǎn)到第二個(gè)控制器

? ?[self presentViewController:twoVc animated:YES completion:nil];

}

@end

6.6RACTuple:元組類(lèi),類(lèi)似NSArray,用來(lái)包裝值.

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

使用場(chǎng)景:1.字典轉(zhuǎn)模型

RACSequence和RACTuple簡(jiǎn)單使用

? ?// 1.遍歷數(shù)組

? ?NSArray *numbers = @[@1,@2,@3,@4];

? ?// 這里其實(shí)是三步

? ?// 第一步: 把數(shù)組轉(zhuǎn)換成集合RACSequence numbers.rac_sequence

? ?// 第二步: 把集合RACSequence轉(zhuǎn)換RACSignal信號(hào)類(lèi),numbers.rac_sequence.signal

? ?// 第三步: 訂閱信號(hào),激活信號(hào),會(huì)自動(dòng)把集合中的所有值,遍歷出來(lái)。

? ?[numbers.rac_sequence.signal subscribeNext:^(id x) {

? ? ? ?NSLog(@"%@",x);

? ?}];

? ?// 2.遍歷字典,遍歷出來(lái)的鍵值對(duì)會(huì)包裝成RACTuple(元組對(duì)象)

? ?NSDictionary *dict = @{@"name":@"xmg",@"age":@18};

? ?[dict.rac_sequence.signal subscribeNext:^(RACTuple *x) {

? ? ? ?// 解包元組,會(huì)把元組的值,按順序給參數(shù)里面的變量賦值

? ? ? ?RACTupleUnpack(NSString *key,NSString *value) = x;

? ? ? ?// 相當(dāng)于以下寫(xiě)法

// ? ? ? ?NSString *key = x[0];

// ? ? ? ?NSString *value = x[1];

? ? ? ?NSLog(@"%@ %@",key,value);

? ?}];

? ?// 3.字典轉(zhuǎn)模型

? ?// 3.1 OC寫(xiě)法

? ?NSString *filePath = [[NSBundle mainBundle] pathForResource:@"flags.plist" ofType:nil];

? ?NSArray *dictArr = [NSArray arrayWithContentsOfFile:filePath];

? ?NSMutableArray *items = [NSMutableArray array];

? ?for (NSDictionary *dict in dictArr) {

? ? ? ?FlagItem *item = [FlagItem flagWithDict:dict];

? ? ? ?[items addObject:item];

? ?}

? ?// 3.2 RAC寫(xiě)法

? ?NSString *filePath = [[NSBundle mainBundle] pathForResource:@"flags.plist" ofType:nil];

? ?NSArray *dictArr = [NSArray arrayWithContentsOfFile:filePath];

? ?NSMutableArray *flags = [NSMutableArray array];

? ?_flags = flags;

? ?// rac_sequence注意點(diǎn):調(diào)用subscribeNext,并不會(huì)馬上執(zhí)行nextBlock,而是會(huì)等一會(huì)。

? ?[dictArr.rac_sequence.signal subscribeNext:^(id x) {

? ? ? ?// 運(yùn)用RAC遍歷字典,x:字典

? ? ? ?FlagItem *item = [FlagItem flagWithDict:x];

? ? ? ?[flags addObject:item];

? ?}];

? ?NSLog(@"%@", ?NSStringFromCGRect([UIScreen mainScreen].bounds));

? ?// 3.3 RAC高級(jí)寫(xiě)法:

? ?NSString *filePath = [[NSBundle mainBundle] pathForResource:@"flags.plist" ofType:nil];

? ?NSArray *dictArr = [NSArray arrayWithContentsOfFile:filePath];

? ?// map:映射的意思,目的:把原始值value映射成一個(gè)新值

? ?// array: 把集合轉(zhuǎn)換成數(shù)組

? ?// 底層實(shí)現(xiàn):當(dāng)信號(hào)被訂閱,會(huì)遍歷集合中的原始值,映射成新值,并且保存到新的數(shù)組里。

? ?NSArray *flags = [[dictArr.rac_sequence map:^id(id value) {

? ? ? ?return [FlagItem flagWithDict:value];

? ?}] array];

6.8RACCommand:RAC中用于處理事件的類(lèi),可以把事件如何處理,事件中的數(shù)據(jù)如何傳遞,包裝到這個(gè)類(lèi)中,他可以很方便的監(jiān)控事件的執(zhí)行過(guò)程。

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

RACCommand簡(jiǎn)單使用

? ? // 一、RACCommand使用步驟:

? ?// 1.創(chuàng)建命令 initWithSignalBlock:(RACSignal * (^)(id input))signalBlock

? ?// 2.在signalBlock中,創(chuàng)建RACSignal,并且作為signalBlock的返回值

? ?// 3.執(zhí)行命令 - (RACSignal *)execute:(id)input

? ?// 二、RACCommand使用注意:

? ?// 1.signalBlock必須要返回一個(gè)信號(hào),不能傳nil.

? ?// 2.如果不想要傳遞信號(hào),直接創(chuàng)建空的信號(hào)[RACSignal empty];

? ?// 3.RACCommand中信號(hào)如果數(shù)據(jù)傳遞完,必須調(diào)用[subscriber sendCompleted],這時(shí)命令才會(huì)執(zhí)行完畢,否則永遠(yuǎn)處于執(zhí)行中。

? ?// 4.RACCommand需要被強(qiáng)引用,否則接收不到RACCommand中的信號(hào),因此RACCommand中的信號(hào)是延遲發(fā)送的。

? ?// 三、RACCommand設(shè)計(jì)思想:內(nèi)部signalBlock為什么要返回一個(gè)信號(hào),這個(gè)信號(hào)有什么用。

? ?// 1.在RAC開(kāi)發(fā)中,通常會(huì)把網(wǎng)絡(luò)請(qǐng)求封裝到RACCommand,直接執(zhí)行某個(gè)RACCommand就能發(fā)送請(qǐng)求。

? ?// 2.當(dāng)RACCommand內(nèi)部請(qǐng)求到數(shù)據(jù)的時(shí)候,需要把請(qǐng)求的數(shù)據(jù)傳遞給外界,這時(shí)候就需要通過(guò)signalBlock返回的信號(hào)傳遞了。

? ?// 四、如何拿到RACCommand中返回信號(hào)發(fā)出的數(shù)據(jù)。

? ?// 1.RACCommand有個(gè)執(zhí)行信號(hào)源executionSignals,這個(gè)是signal of signals(信號(hào)的信號(hào)),意思是信號(hào)發(fā)出的數(shù)據(jù)是信號(hào),不是普通的類(lèi)型。

? ?// 2.訂閱executionSignals就能拿到RACCommand中返回的信號(hào),然后訂閱signalBlock返回的信號(hào),就能獲取發(fā)出的值。

? ?// 五、監(jiān)聽(tīng)當(dāng)前命令是否正在執(zhí)行executing

? ?// 六、使用場(chǎng)景,監(jiān)聽(tīng)按鈕點(diǎn)擊,網(wǎng)絡(luò)請(qǐng)求

? ?// 1.創(chuàng)建命令

? ?RACCommand *command = [[RACCommand alloc] initWithSignalBlock:^RACSignal *(id input) {

? ? ? ?NSLog(@"執(zhí)行命令");

? ? ? ?// 創(chuàng)建空信號(hào),必須返回信號(hào)

? ? ? ?// ? ? ? ?return [RACSignal empty];

? ? ? ?// 2.創(chuàng)建信號(hào),用來(lái)傳遞數(shù)據(jù)

? ? ? ?return [RACSignal createSignal:^RACDisposable *(id subscriber) {

? ? ? ? ? ?[subscriber sendNext:@"請(qǐng)求數(shù)據(jù)"];

? ? ? ? ? ?// 注意:數(shù)據(jù)傳遞完,最好調(diào)用sendCompleted,這時(shí)命令才執(zhí)行完畢。

? ? ? ? ? ?[subscriber sendCompleted];

? ? ? ? ? ?return nil;

? ? ? ?}];

? ?}];

? ?// 強(qiáng)引用命令,不要被銷(xiāo)毀,否則接收不到數(shù)據(jù)

? ?_conmmand = command;

? ?// 3.訂閱RACCommand中的信號(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)

? ?[command.executionSignals.switchToLatest subscribeNext:^(id x) {

? ? ? ?NSLog(@"%@",x);

? ?}];

? ?// 4.監(jiān)聽(tīng)命令是否執(zhí)行完畢,默認(rèn)會(huì)來(lái)一次,可以直接跳過(guò),skip表示跳過(guò)第一次信號(hào)。

? ?[[command.executing skip:1] subscribeNext:^(id x) {

? ? ? ?if ([x boolValue] == YES) {

? ? ? ? ? ?// 正在執(zhí)行

? ? ? ? ? ?NSLog(@"正在執(zhí)行");

? ? ? ?}else{

? ? ? ? ? ?// 執(zhí)行完成

? ? ? ? ? ?NSLog(@"執(zhí)行完成");

? ? ? ?}

? ?}];

? // 5.執(zhí)行命令

? ?[self.conmmand execute:@1];

6.9RACMulticastConnection:用于當(dāng)一個(gè)信號(hào),被多次訂閱時(shí),為了保證創(chuàng)建信號(hào)時(shí),避免多次調(diào)用創(chuàng)建信號(hào)中的block,造成副作用,可以使用這個(gè)類(lèi)處理。

使用注意:RACMulticastConnection通過(guò)RACSignal的-publish或者-muticast:方法創(chuàng)建.

RACMulticastConnection簡(jiǎn)單使用:

? ?// RACMulticastConnection使用步驟:

? ?// 1.創(chuàng)建信號(hào) + (RACSignal *)createSignal:(RACDisposable * (^)(id subscriber))didSubscribe

? ?// 2.創(chuàng)建連接 RACMulticastConnection *connect = [signal publish];

? ?// 3.訂閱信號(hào),注意:訂閱的不在是之前的信號(hào),而是連接的信號(hào)。 [connect.signal subscribeNext:nextBlock]

? ?// 4.連接 [connect connect]

? ?// RACMulticastConnection底層原理:

? ?// 1.創(chuàng)建connect,connect.sourceSignal -> RACSignal(原始信號(hào)) ?connect.signal -> RACSubject

? ?// 2.訂閱connect.signal,會(huì)調(diào)用RACSubject的subscribeNext,創(chuàng)建訂閱者,而且把訂閱者保存起來(lái),不會(huì)執(zhí)行block。

? ?// 3.[connect connect]內(nèi)部會(huì)訂閱RACSignal(原始信號(hào)),并且訂閱者是RACSubject

? ?// 3.1.訂閱原始信號(hào),就會(huì)調(diào)用原始信號(hào)中的didSubscribe

? ?// 3.2 didSubscribe,拿到訂閱者調(diào)用sendNext,其實(shí)是調(diào)用RACSubject的sendNext

? ?// 4.RACSubject的sendNext,會(huì)遍歷RACSubject所有訂閱者發(fā)送信號(hào)。

? ?// 4.1 因?yàn)閯倓偟诙?,都是在訂閱RACSubject,因此會(huì)拿到第二步所有的訂閱者,調(diào)用他們的nextBlock

? ?// 需求:假設(shè)在一個(gè)信號(hào)中發(fā)送請(qǐng)求,每次訂閱一次都會(huì)發(fā)送請(qǐng)求,這樣就會(huì)導(dǎo)致多次請(qǐng)求。

? ?// 解決:使用RACMulticastConnection就能解決.

? ?// 1.創(chuàng)建請(qǐng)求信號(hào)

? RACSignal *signal = [RACSignal createSignal:^RACDisposable *(id subscriber) {

? ? ? ?NSLog(@"發(fā)送請(qǐng)求");

? ? ? ?return nil;

? ?}];

? ?// 2.訂閱信號(hào)

? ?[signal subscribeNext:^(id x) {

? ? ? ?NSLog(@"接收數(shù)據(jù)");

? ?}];

? ?// 2.訂閱信號(hào)

? ?[signal subscribeNext:^(id x) {

? ? ? ?NSLog(@"接收數(shù)據(jù)");

? ?}];

? ?// 3.運(yùn)行結(jié)果,會(huì)執(zhí)行兩遍發(fā)送請(qǐng)求,也就是每次訂閱都會(huì)發(fā)送一次請(qǐng)求

? ?// RACMulticastConnection:解決重復(fù)請(qǐng)求問(wèn)題

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

? ?RACSignal *signal = [RACSignal createSignal:^RACDisposable *(id subscriber) {

? ? ? ?NSLog(@"發(fā)送請(qǐng)求");

? ? ? ?[subscriber sendNext:@1];

? ? ? ?return nil;

? ?}];

? ?// 2.創(chuàng)建連接

? ?RACMulticastConnection *connect = [signal publish];

? ?// 3.訂閱信號(hào),

? ?// 注意:訂閱信號(hào),也不能激活信號(hào),只是保存訂閱者到數(shù)組,必須通過(guò)連接,當(dāng)調(diào)用連接,就會(huì)一次性調(diào)用所有訂閱者的sendNext:

? ?[connect.signal subscribeNext:^(id x) {

? ? ? ?NSLog(@"訂閱者一信號(hào)");

? ?}];

? ?[connect.signal subscribeNext:^(id x) {

? ? ? ?NSLog(@"訂閱者二信號(hào)");

? ?}];

? ?// 4.連接,激活信號(hào)

? ?[connect connect];

6.10 RACScheduler:RAC中的隊(duì)列,用GCD封裝的。

6.11 RACUnit :表?stream不包含有意義的值,也就是看到這個(gè),可以直接理解為nil.

6.12 RACEvent: 把數(shù)據(jù)包裝成信號(hào)事件(signal event)。它主要通過(guò)RACSignal的-materialize來(lái)使用,然并卵。

7.ReactiveCocoa開(kāi)發(fā)中常見(jiàn)用法。

7.1 代替代理:

* rac_signalForSelector:用于替代代理。

7.2 代替KVO :

* rac_valuesAndChangesForKeyPath:用于監(jiān)聽(tīng)某個(gè)對(duì)象的屬性改變。

7.3 監(jiān)聽(tīng)事件:

* rac_signalForControlEvents:用于監(jiān)聽(tīng)某個(gè)事件。

7.4 代替通知:

* rac_addObserverForName:用于監(jiān)聽(tīng)某個(gè)通知。

7.5 監(jiān)聽(tīng)文本框文字改變:

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

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

* rac_liftSelector:withSignalsFromArray:Signals:當(dāng)傳入的Signals(信號(hào)數(shù)組),每一個(gè)signal都至少sendNext過(guò)一次,就會(huì)去觸發(fā)第一個(gè)selector參數(shù)的方法。

* 使用注意:幾個(gè)信號(hào),參數(shù)一的方法就幾個(gè)參數(shù),每個(gè)參數(shù)對(duì)應(yīng)信號(hào)發(fā)出的數(shù)據(jù)。

7.7 代碼演示

? ? ?// 1.代替代理

? ?// 需求:自定義redView,監(jiān)聽(tīng)紅色view中按鈕點(diǎn)擊

? ?// 之前都是需要通過(guò)代理監(jiān)聽(tīng),給紅色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)聽(tīng)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)聽(tīng)事件

? ?// 把按鈕點(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)聽(tīng)到的通知轉(zhuǎn)換信號(hào)

? ?[[[NSNotificationCenter defaultCenter] rac_addObserverForName:UIKeyboardWillShowNotification object:nil] subscribeNext:^(id x) {

? ? ? ?NSLog(@"鍵盤(pán)彈出");

? ?}];

? ?// 5.監(jiān)聽(tīng)文本框的文字改變

? [_textField.rac_textSignal subscribeNext:^(id x) {

? ? ? NSLog(@"文字改變了%@",x);

? }];

? // 6.處理多個(gè)請(qǐng)求,都返回結(jié)果的時(shí)候,統(tǒng)一做處理.

? ?RACSignal *request1 = [RACSignal createSignal:^RACDisposable *(id subscriber) {

? ? ? ?// 發(fā)送請(qǐng)求1

? ? ? ?[subscriber sendNext:@"發(fā)送請(qǐng)求1"];

? ? ? ?return nil;

? ?}];

? ?RACSignal *request2 = [RACSignal createSignal:^RACDisposable *(id 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);

}

8.ReactiveCocoa常見(jiàn)宏。

8.1 RAC(TARGET, [KEYPATH, [NIL_VALUE]]):用于給某個(gè)對(duì)象的某個(gè)屬性綁定。

? ?// 只要文本框文字改變,就會(huì)修改label的文字

? ?RAC(self.labelView,text) = _textField.rac_textSignal;

8.2 RACObserve(self, name):監(jiān)聽(tīng)某個(gè)對(duì)象的某個(gè)屬性,返回的是信號(hào)。

[RACObserve(self.view, center) subscribeNext:^(id x) {

? ? ? ?NSLog(@"%@",x);

? ?}];

8.3 ?@weakify(Obj)和@strongify(Obj),一般兩個(gè)都是配套使用,在主頭文件(ReactiveCocoa.h)中并沒(méi)有導(dǎo)入,需要自己手動(dòng)導(dǎo)入,RACEXTScope.h才可以使用。但是每次導(dǎo)入都非常麻煩,只需要在主頭文件自己導(dǎo)入就好了。

8.4 RACTuplePack:把數(shù)據(jù)包裝成RACTuple(元組類(lèi))

// 把參數(shù)中的數(shù)據(jù)包裝成元組

? ?RACTuple *tuple = RACTuplePack(@10,@20);

8.5 RACTupleUnpack:把RACTuple(元組類(lèi))解包成對(duì)應(yīng)的數(shù)據(jù)。

? ?// 把參數(shù)中的數(shù)據(jù)包裝成元組

? ?RACTuple *tuple = RACTuplePack(@"xmg",@20);

? ?// 解包元組,會(huì)把元組的值,按順序給參數(shù)里面的變量賦值

? ?// name = @"xmg" age = @20

? ?RACTupleUnpack(NSString *name,NSNumber *age) = tuple;


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

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

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