ReactiveCocoa學(xué)習(xí)之RACSignal

寫(xiě)這篇文章的目的倒谷,在于記錄自己的學(xué)習(xí)內(nèi)容,理順?biāo)悸贰?/p>

RAC(Reactive Cocoa)

Cocoa是蘋(píng)果整套框架的簡(jiǎn)稱(chēng)。Reactive響應(yīng)俯艰。
第一次聽(tīng)說(shuō)RAC,是有人問(wèn)我窒典,你知道函數(shù)響應(yīng)式編程嗎蟆炊?
RAC就是。

那么瀑志,什么是函數(shù)響應(yīng)式編程涩搓?
RAC讓人覺(jué)得厲害的大概就是它的編程思想,事件的處理劈猪,經(jīng)常會(huì)有一種讓人忍不住贊嘆一聲昧甘,啊战得!或是一語(yǔ)驚醒夢(mèng)中人的頓悟感充边。哈哈,我這個(gè)小白常侦,在學(xué)習(xí)的過(guò)程中浇冰,是這樣子沒(méi)錯(cuò)啦。

函數(shù)式編程:

相關(guān)操作使用函數(shù)或者方法調(diào)用聋亡。
特點(diǎn):每個(gè)方法都有返回值肘习,并且使用block或函數(shù)作為參數(shù)。

顧名思義坡倔,采用函數(shù)的思想漂佩。
函數(shù)式編程,多采用閉包與高階函數(shù)罪塔,函數(shù)是“第一等公民”投蝉,惰性計(jì)算(只用“表達(dá)式”,不用“語(yǔ)句”)征堪,遞歸(無(wú)“副作用”)瘩缆,不修改狀態(tài)(引用透明性)。

例如佃蚜,數(shù)學(xué)中常見(jiàn)的函數(shù)表達(dá)式
y = f(x) ——> y = f(f(x)) ,該表達(dá)式的參數(shù)是一個(gè)函數(shù)
應(yīng)用到OC中庸娱,形式就大概如下

- (void)test:(void(^)(NSString *))block{
    
    block = ^(NSString *name){
//表達(dá)式
    };
}

響應(yīng)式編程:

這種于操作結(jié)果,而不在意該結(jié)果究竟是按照怎樣的操作順序發(fā)生變化導(dǎo)致的爽锥。有點(diǎn)類(lèi)似于蝴蝶效應(yīng),a發(fā)生變化畔柔,b自然跟隨發(fā)生變化氯夷。
例如:

int a = 10;
int b = a+10;

我們希望a的值改變時(shí),b的值隨之改變靶擦,這就是響應(yīng)腮考,b自然響應(yīng)a

具體雇毫,推薦閱讀袁崢大神的http://www.reibang.com/p/87ef6720a096
幾種常見(jiàn)的編程思想介紹具體,而且還有使用例子踩蔚。

RAC類(lèi)結(jié)構(gòu)圖.jpg

RACSignal

RAC的使用過(guò)程棚放,不外乎于
1.信號(hào)的產(chǎn)生 2.訂閱信號(hào) 3.發(fā)送信號(hào) 4.信號(hào)銷(xiāo)毀。

//1:信號(hào)的產(chǎn)生
    RACSignal *signal = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        // block調(diào)用時(shí)刻:每當(dāng)有訂閱者訂閱信號(hào)馅闽,就會(huì)調(diào)用block飘蚯。
        //3:發(fā)送信號(hào)
        [subscriber sendNext:@"龍晨"];

        // 如果不在發(fā)送數(shù)據(jù),最好發(fā)送信號(hào)完成福也,內(nèi)部會(huì)自動(dòng)調(diào)用[RACDisposable disposable]取消訂閱信號(hào)局骤。

        NSError *error = [[NSError alloc] initWithDomain:NSURLErrorDomain code:1008611 userInfo:@{@"key":@"我的錯(cuò)"}];
        [subscriber sendError:error];
        
        //4:信號(hào)銷(xiāo)毀
        //RACDisposable 信號(hào)回收站
        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)毀了");
        }];
    }];
    
    //2:訂閱信號(hào)
    [signal subscribeNext:^(id  _Nullable x) {
// block調(diào)用時(shí)刻:每當(dāng)有信號(hào)發(fā)出數(shù)據(jù)现喳,就會(huì)調(diào)用block.
        NSLog(@"%@",x);
    }];
    
    [signal subscribeError:^(NSError * _Nullable error) {
        NSLog(@"%@",error);
    }];

代碼自上而下調(diào)用凯傲,那么3和4的發(fā)生,為什么會(huì)在2之后呢嗦篱?明明3和4的代碼在前呀冰单?
為什么呢?

RACSignal,信號(hào)類(lèi)默色,默認(rèn)是冷信號(hào)球凰,只有訂閱了這個(gè)信號(hào),才會(huì)變?yōu)闊嵝盘?hào)腿宰,值發(fā)生變化時(shí)觸發(fā)呕诉。
訂閱信號(hào),調(diào)用RACSignal的subscribeNext方法吃度。

1.創(chuàng)建信號(hào)甩挫,調(diào)用的方法

+ (RACSignal *)createSignal:(RACDisposable * (^)(id<RACSubscriber> subscriber))didSubscribe {
    return [RACDynamicSignal createSignal:didSubscribe];
}

我們注意到,該方法的參數(shù)為didSubscribe的一個(gè)block椿每,返回值是一個(gè)RACDynamicSignal類(lèi)伊者。

+ (RACSignal *)createSignal:(RACDisposable * (^)(id<RACSubscriber> subscriber))didSubscribe {
    RACDynamicSignal *signal = [[self alloc] init];
    signal->_didSubscribe = [didSubscribe copy];
    return [signal setNameWithFormat:@"+createSignal:"];
}

在該方法中,didSubscribe被保存起來(lái)间护,此時(shí)并不會(huì)觸發(fā)亦渗。

2.當(dāng)信號(hào)被訂閱時(shí),在創(chuàng)建RACSubscriber的同時(shí)汁尺,nextBlock也被保存起來(lái)

- (RACDisposable *)subscribeNext:(void (^)(id x))nextBlock {
    NSCParameterAssert(nextBlock != NULL);
    
    RACSubscriber *o = [RACSubscriber subscriberWithNext:nextBlock error:NULL completed:NULL];
    return [self subscribe:o];
}
- (RACDisposable *)subscribe:(id<RACSubscriber>)subscriber {
    NSCParameterAssert(subscriber != nil);

    RACCompoundDisposable *disposable = [RACCompoundDisposable compoundDisposable];
    subscriber = [[RACPassthroughSubscriber alloc] initWithSubscriber:subscriber signal:self disposable:disposable];

    if (self.didSubscribe != NULL) {
        RACDisposable *schedulingDisposable = [RACScheduler.subscriptionScheduler schedule:^{
            RACDisposable *innerDisposable = self.didSubscribe(subscriber);
            [disposable addDisposable:innerDisposable];
        }];

        [disposable addDisposable:schedulingDisposable];
    }
    
    return disposable;
}

+ (instancetype)subscriberWithNext:(void (^)(id x))next error:(void (^)(NSError *error))error completed:(void (^)(void))completed {
    RACSubscriber *subscriber = [[self alloc] init];

    subscriber->_next = [next copy];
    subscriber->_error = [error copy];
    subscriber->_completed = [completed copy];

    return subscriber;
}

- (instancetype)init {
    self = [super init];

    @unsafeify(self);

    RACDisposable *selfDisposable = [RACDisposable disposableWithBlock:^{
        @strongify(self);

        @synchronized (self) {
            self.next = nil;
            self.error = nil;
            self.completed = nil;
        }
    }];

    _disposable = [RACCompoundDisposable compoundDisposable];
    [_disposable addDisposable:selfDisposable];

    return self;
}

同時(shí)還創(chuàng)建了RACCompoundDisposable與RACPassthroughSubscriber(真正的訂閱者類(lèi))衣撬,同時(shí)RACDynamicSignal的didSubscribe被調(diào)用往枣。
而在didSubscribe中刑巧,會(huì)調(diào)用[subscriber sendNext:];

#pragma mark RACSubscriber

- (void)sendNext:(id)value {
    if (self.disposable.disposed) return;

    if (RACSIGNAL_NEXT_ENABLED()) {
        RACSIGNAL_NEXT(cleanedSignalDescription(self.signal), cleanedDTraceString(self.innerSubscriber.description), cleanedDTraceString([value description]));
    }

    [self.innerSubscriber sendNext:value];
}

- (void)sendNext:(id)value {
    @synchronized (self) {
        void (^nextBlock)(id) = [self.next copy];
        if (nextBlock == nil) return;

        nextBlock(value);
    }
}

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

RACSignal可用于textFiled,button,手勢(shì),通知狼荞,KVO,定時(shí)器等帮碰。

 @weakify(self);
    //textField
    [self.accountTF.rac_textSignal subscribeNext:^(NSString * _Nullable x) {
            @strongify(self);
        self.imgV.image = [UIImage imageNamed:x];
        if (self.imgV.image == nil) {
            self.imgV.image = [UIImage imageNamed:@"touxiang"];
        }
    }];
    
    //button
    [[self.loginBtn rac_signalForControlEvents:UIControlEventTouchUpInside] subscribeNext:^(__kindof UIControl * _Nullable x) {
            @strongify(self);
        
    }];
    
    
    //定時(shí)器
    [[RACSignal interval:1 onScheduler:[RACScheduler scheduler]] subscribeNext:^(NSDate * _Nullable x) {
        NSLog(@"%@",x);
    }];
    
    //手勢(shì)
    UITapGestureRecognizer *tap = [UITapGestureRecognizer new];
    self.stateLabel.userInteractionEnabled = YES;
    [self.stateLabel addGestureRecognizer:tap];
    [[tap rac_gestureSignal] subscribeNext:^(__kindof UIGestureRecognizer * _Nullable x) {
        NSLog(@"%@",x);
    }];
    
    //通知
    [[[NSNotificationCenter defaultCenter] rac_addObserverForName:UIKeyboardDidChangeFrameNotification object:nil] subscribeNext:^(NSNotification * _Nullable x) {
        NSLog(@"%@",x);
    }];
    
    //KVO
    [RACObserve(self, name) subscribeNext:^(id  _Nullable x) {
        NSLog(@"%@",x);
    }];

RAC中常見(jiàn)的相關(guān)操作:

1.信號(hào)映射:map與flattenMap
2.信號(hào)過(guò)濾:filter相味、ignore、 distinctUntilChanged
3.信號(hào)合并: combineLatest殉挽、reduce丰涉、merge、zipWith
4.信號(hào)連接:concat此再、then
5.信號(hào)操作時(shí)間:timeout昔搂、interval、dely
6.信號(hào)取值:take输拇、takeLast摘符、takeUntil、
7.信號(hào)跳過(guò):skip
8.信號(hào)發(fā)送順序:donext策吠、cocompleted
9.獲取信號(hào)中的信號(hào):switchToLatest
10.信號(hào)錯(cuò)誤重試:retry

簡(jiǎn)單使用舉例:

//map  flattenMap
    //實(shí)際應(yīng)用時(shí) 通常會(huì)跳過(guò)第一次
    [[[self.accountTF.rac_textSignal skip:1] flattenMap:^__kindof RACSignal * _Nullable(NSString * _Nullable value) {
        
        return [RACSignal return:[NSString stringWithFormat:@"+86-%@",value]];
        
    }]  subscribeNext:^(id  _Nullable x) {
        NSLog(@"flattenMap  ===  %@",x);
    }];
    
    
    //filter
    [[[self.passwordTF.rac_textSignal skip:1] filter:^BOOL(NSString * _Nullable value) {
        //做過(guò)濾條件
        @strongify(self);
        if (self.passwordTF.text.length > 5) {
            self.passwordTF.text = [self.passwordTF.text substringToIndex:5];
            self.stateLabel.text = @"密碼長(zhǎng)度不能大于5";
        }
        return value.length < 5;
        
    }] subscribeNext:^(NSString * _Nullable x) {
      NSLog(@"我訂閱到了什么:%@",x);
        //邏輯區(qū)域
    }] ;

    
    //組合 combineLaster
    RACSignal *signalA = self.accountTF.rac_textSignal;
    RACSignal *signalB = self.passwordTF.rac_textSignal;
    
    [[RACSignal combineLatest:@[signalA, signalB] reduce:^id (NSString *account,NSString *password){
        //reduceBlock的參數(shù)個(gè)數(shù) 要與 合并的信號(hào)數(shù)組的個(gè)數(shù)保持一致
        //此處 可以將多個(gè)參數(shù)合并
        return @(account.length && password.length);
    }] subscribeNext:^(NSNumber *x) {
        self.loginBtn.backgroundColor = x.integerValue ? [UIColor greenColor] : [UIColor darkGrayColor];
        self.loginBtn.enabled = x.integerValue;
    }];
    
    //takeUntil
    //subject1 正常發(fā)送逛裤,直到subject2發(fā)送信號(hào)。意味著subject2發(fā)送信號(hào)后 subject1不能再發(fā)送信號(hào)
    //以下代碼猴抹,reboot不能正常發(fā)送带族,除非注釋掉 [subject2 sendNext:@"hani"];
    
    RACSubject *subject1 = [RACSubject subject];
    RACSubject *subject2 = [RACSubject subject];
    
    [[subject1 takeUntil:subject2] subscribeNext:^(id  _Nullable x) {
        
        NSLog(@"%@",x);
    }];
    
    [subject1 sendNext:@"菲尼克斯"];
    [subject1 sendNext:@"艾拇"];
    
    [subject2 sendNext:@"hani"];
    
    [subject1 sendNext:@"reboot"];

說(shuō)明:

(a)flattenMap:在bind基礎(chǔ)上封裝的改變 法, 提 供的block蟀给,改變當(dāng)前流蝙砌,變成block返回的流對(duì)象。
(b)flatten:在flattenMap基礎(chǔ)封裝的改變 法跋理,如果當(dāng)前 反應(yīng)流中的對(duì)象也是 個(gè)流的話(huà)择克,就可以將當(dāng)前流變成當(dāng)前
流中的流對(duì)象
(c)map:在flattenMap基礎(chǔ)上封裝的改變 法,在 flattenMap中的block中返回的值必須也是流對(duì)象前普, map則
需要肚邢,它是將流中的對(duì)象執(zhí) block后, 流的return 法 將值變成流對(duì)象拭卿。
(d)mapReplace:在map的基礎(chǔ)上封裝的改變 法骡湖,直接 替換當(dāng)前流中的對(duì)象,形成 個(gè)新的對(duì)象流峻厚。
(e)filter:在Map基礎(chǔ)上封裝的改變封裝响蕴,過(guò)濾掉當(dāng)前流 中 符合要求的對(duì)象,將之變?yōu)榭樟?br> (f)ignore:在filter基礎(chǔ)封裝的改變 法惠桃,忽 和當(dāng) 前值 樣的對(duì)象浦夷,將之變?yōu)榭樟?br> (g)skip:在bind基礎(chǔ)上封裝的改變 法懊渡,忽 當(dāng)前 流前n次的對(duì)象值,將之變?yōu)榭樟?br> (h)take:在bind基礎(chǔ)上封裝的改變 法军拟,只區(qū)當(dāng) 前流中的前n次對(duì)象值,之后將流變?yōu)榭? 是空
流)誓禁。
(i)distinctUntilChanged:在bind基礎(chǔ)封裝的改變 法懈息,當(dāng)流中后 次的值和前 次的值 同的時(shí)候,
才會(huì)返回當(dāng)前值的流摹恰,否則返回空流(第 次默認(rèn)被 忽 )
(j)takeUntilBlock:在bind基礎(chǔ)封裝的改變 法辫继,取當(dāng)前 流的對(duì)象值,直到當(dāng)前值滿(mǎn) 提供的block俗慈,就會(huì)將當(dāng)前流
變?yōu)榭? 是空流)
(k)takeWhileBlock:在bind基礎(chǔ)封裝的改變 法姑宽,取當(dāng)
前流的對(duì)象值,直到當(dāng)前值 滿(mǎn) 提供的block闺阱,就會(huì)將當(dāng) 前流變?yōu)榭? 是空流)
(l)skipUntilBlock:在bind基礎(chǔ)封裝的改變 法炮车,忽 當(dāng) 前流的對(duì)象值(變?yōu)榭樟?,直到當(dāng)前值滿(mǎn) 提供的
block酣溃。
(m)skipWhileBlock:在bind基礎(chǔ)封裝的改變 法瘦穆,忽 當(dāng)前流的對(duì)象值(變?yōu)榭樟?,直到當(dāng)前值 滿(mǎn) 提供的 block
(n)scanWithStart: reduceWithIndex:在bind基
礎(chǔ)封裝的改變 法赊豌, 同樣的block執(zhí) 每次流中的
值扛或,并將結(jié)果 于后 次執(zhí) 當(dāng)中,每次都把block 執(zhí) 后的值變成新的流中的對(duì)象碘饼。
(o)startWIth:在contact基礎(chǔ)上封裝的多流之間 的順序 法熙兔,在當(dāng)前流的值流出之前,加 個(gè)初
始值 (p)zip:打包多流艾恼,將多個(gè)流中的值包裝成 個(gè)
RACTuple對(duì)象
(q)reduceEach:將流中的RACTuple對(duì)象進(jìn) 過(guò) 濾住涉,返回特定的衍 出的 個(gè)值對(duì)象

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
  • 序言:七十年代末,一起剝皮案震驚了整個(gè)濱河市蒂萎,隨后出現(xiàn)的幾起案子秆吵,更是在濱河造成了極大的恐慌,老刑警劉巖五慈,帶你破解...
    沈念sama閱讀 216,919評(píng)論 6 502
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件纳寂,死亡現(xiàn)場(chǎng)離奇詭異,居然都是意外死亡泻拦,警方通過(guò)查閱死者的電腦和手機(jī)毙芜,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 92,567評(píng)論 3 392
  • 文/潘曉璐 我一進(jìn)店門(mén),熙熙樓的掌柜王于貴愁眉苦臉地迎上來(lái)争拐,“玉大人腋粥,你說(shuō)我怎么就攤上這事晦雨。” “怎么了隘冲?”我有些...
    開(kāi)封第一講書(shū)人閱讀 163,316評(píng)論 0 353
  • 文/不壞的土叔 我叫張陵闹瞧,是天一觀的道長(zhǎng)。 經(jīng)常有香客問(wèn)我展辞,道長(zhǎng)奥邮,這世上最難降的妖魔是什么? 我笑而不...
    開(kāi)封第一講書(shū)人閱讀 58,294評(píng)論 1 292
  • 正文 為了忘掉前任罗珍,我火速辦了婚禮洽腺,結(jié)果婚禮上,老公的妹妹穿的比我還像新娘覆旱。我一直安慰自己蘸朋,他們只是感情好,可當(dāng)我...
    茶點(diǎn)故事閱讀 67,318評(píng)論 6 390
  • 文/花漫 我一把揭開(kāi)白布扣唱。 她就那樣靜靜地躺著藕坯,像睡著了一般。 火紅的嫁衣襯著肌膚如雪噪沙。 梳的紋絲不亂的頭發(fā)上堕担,一...
    開(kāi)封第一講書(shū)人閱讀 51,245評(píng)論 1 299
  • 那天,我揣著相機(jī)與錄音曲聂,去河邊找鬼霹购。 笑死,一個(gè)胖子當(dāng)著我的面吹牛朋腋,可吹牛的內(nèi)容都是我干的齐疙。 我是一名探鬼主播,決...
    沈念sama閱讀 40,120評(píng)論 3 418
  • 文/蒼蘭香墨 我猛地睜開(kāi)眼旭咽,長(zhǎng)吁一口氣:“原來(lái)是場(chǎng)噩夢(mèng)啊……” “哼贞奋!你這毒婦竟也來(lái)了?” 一聲冷哼從身側(cè)響起穷绵,我...
    開(kāi)封第一講書(shū)人閱讀 38,964評(píng)論 0 275
  • 序言:老撾萬(wàn)榮一對(duì)情侶失蹤轿塔,失蹤者是張志新(化名)和其女友劉穎,沒(méi)想到半個(gè)月后仲墨,有當(dāng)?shù)厝嗽跇?shù)林里發(fā)現(xiàn)了一具尸體勾缭,經(jīng)...
    沈念sama閱讀 45,376評(píng)論 1 313
  • 正文 獨(dú)居荒郊野嶺守林人離奇死亡,尸身上長(zhǎng)有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 37,592評(píng)論 2 333
  • 正文 我和宋清朗相戀三年目养,在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了俩由。 大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片。...
    茶點(diǎn)故事閱讀 39,764評(píng)論 1 348
  • 序言:一個(gè)原本活蹦亂跳的男人離奇死亡癌蚁,死狀恐怖幻梯,靈堂內(nèi)的尸體忽然破棺而出兜畸,到底是詐尸還是另有隱情,我是刑警寧澤碘梢,帶...
    沈念sama閱讀 35,460評(píng)論 5 344
  • 正文 年R本政府宣布咬摇,位于F島的核電站,受9級(jí)特大地震影響煞躬,放射性物質(zhì)發(fā)生泄漏菲嘴。R本人自食惡果不足惜,卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 41,070評(píng)論 3 327
  • 文/蒙蒙 一汰翠、第九天 我趴在偏房一處隱蔽的房頂上張望。 院中可真熱鬧昭雌,春花似錦复唤、人聲如沸。這莊子的主人今日做“春日...
    開(kāi)封第一講書(shū)人閱讀 31,697評(píng)論 0 22
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽(yáng)。三九已至总放,卻和暖如春呈宇,著一層夾襖步出監(jiān)牢的瞬間,已是汗流浹背局雄。 一陣腳步聲響...
    開(kāi)封第一講書(shū)人閱讀 32,846評(píng)論 1 269
  • 我被黑心中介騙來(lái)泰國(guó)打工甥啄, 沒(méi)想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留,地道東北人炬搭。 一個(gè)月前我還...
    沈念sama閱讀 47,819評(píng)論 2 370
  • 正文 我出身青樓蜈漓,卻偏偏與公主長(zhǎng)得像,于是被迫代替她去往敵國(guó)和親宫盔。 傳聞我的和親對(duì)象是個(gè)殘疾皇子融虽,可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 44,665評(píng)論 2 354