文章系列
《ReactiveCocoa 概述》
《RACSignal》
《RACDisposable》
《RACSubject、RACReplaySubject(內(nèi)附冷信號(hào)和熱信號(hào)的區(qū)別)》
《集合RACTuple、RACSequence》
《RAC 中的通知、代理、KVO, 基本事件、方法的監(jiān)聽(tīng)》
《rac_liftSelector》
《RACMulticastConnection》
《RACCommand》
《RAC - 核心方法bind》
《RAC - 定時(shí)器》
《RACScheduler》
《RAC - 點(diǎn)擊獲取驗(yàn)證碼 demo》
《RAC - 映射(Map & flattenMap)》
《RAC信號(hào)操作解釋合集》
《RAC - 信號(hào)的生命周期》

RACSignal: 信號(hào)類(lèi), 本身不具備發(fā)送信號(hào)的能力, 當(dāng)被訂閱后, 用于傳遞改變的數(shù)據(jù), 可傳遞以下三種狀態(tài)：

• sendNext(id)：可理解為傳遞正確數(shù)據(jù)，告訴訂閱者進(jìn)行下一步處理
• sendError：傳遞的數(shù)據(jù)錯(cuò)誤，告訴訂閱者錯(cuò)誤處理
• sendCompleted：告訴訂閱者已完成

• 流程圖:
  signal.png

• 代碼分析 (注釋很詳細(xì)!!!)

- (void)signalTest {
    
    /* 1. 創(chuàng)建信號(hào) signal
            - 通過(guò) createSignal: 方法創(chuàng)建,其參數(shù)為一個(gè)返回值位RACDisposable 類(lèi)型的block (didSubcribe)
     */
    RACSignal *signal = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        
        // 2. 通過(guò)block 傳入的訂閱者subscriber 來(lái)發(fā)送信息
        [subscriber sendNext:@10];
        
        // sendError、sendCompleted 二者只能發(fā)送其一,  就代表結(jié)束了.
        [subscriber sendError:[NSError errorWithDomain:@"錯(cuò)誤" code:1001 userInfo:nil]];
        [subscriber sendCompleted];
        // 這里需要返回一個(gè)RACDisposable 類(lèi)型的對(duì)象, 用于提前結(jié)束訂閱等操作, 一般無(wú)特殊需求, 返回nil 即可.
        return nil;
    }];
    
    /* 3. 訂閱者 (subscriber)
            - subscribeNext + error + completed 組合起來(lái)就是訂閱者
            - 一旦訂閱者訂閱了信號(hào)消息, 就會(huì)執(zhí)行上面的didSubcribe 的block.
     */
    [signal subscribeNext:^(id  _Nullable x) {
        NSLog(@"%@", x);
    } error:^(NSError * _Nullable error) {
        NSLog(@"ERROR=%@", error);
    } completed:^{
        NSLog(@"完成");
    }];
}

• ↓分析 [RACSignal createSignal:]內(nèi)部實(shí)現(xiàn)↓:

// 第1次點(diǎn)擊方法跳轉(zhuǎn)內(nèi)部實(shí)現(xiàn):
+ (RACSignal *)createSignal:(RACDisposable * (^)(id<RACSubscriber> subscriber))didSubscribe {
    // 內(nèi)部創(chuàng)建RACDynamicSignal 信號(hào), 并將外部block 繼續(xù)傳遞
    return [RACDynamicSignal createSignal:didSubscribe];
}

// 第2次點(diǎn)擊方法跳轉(zhuǎn)內(nèi)部實(shí)現(xiàn):
+ (RACSignal *)createSignal:(RACDisposable * (^)(id<RACSubscriber> subscriber))didSubscribe {
    // 1. 創(chuàng)建 RACDynamicSignal對(duì)象
    // 2. 保存以參數(shù)形式傳遞進(jìn)來(lái)的 block
    // 3. 返回 RACDynamicSignal 對(duì)象
    RACDynamicSignal *signal = [[self alloc] init];
    signal->_didSubscribe = [didSubscribe copy];
    return [signal setNameWithFormat:@"+createSignal:"];
}

• ↓分析 訂閱者 訂閱過(guò)程的實(shí)現(xiàn)(源碼邏輯分析, 幫助理解)↓:

    // 開(kāi)始訂閱
    [signal subscribeNext:^(id  _Nullable x) {
        // 訂閱信號(hào)之后得到帶有一個(gè)參數(shù)為 x的 block
        NSLog(@"%@", x);
    }];

// 點(diǎn)擊 [signal subscribeNext:]內(nèi)部實(shí)現(xiàn)
- (RACDisposable *)subscribeNext:(void (^)(id x))nextBlock {
    NSCParameterAssert(nextBlock != NULL);
    // 創(chuàng)建訂閱者 o
    RACSubscriber *o = [RACSubscriber subscriberWithNext:nextBlock error:NULL completed:NULL];
    return [self subscribe:o];
}

// 點(diǎn)擊[RACSubscriber subscriberWithNext:] 內(nèi)部實(shí)現(xiàn)
+ (instancetype)subscriberWithNext:(void (^)(id x))next error:(void (^)(NSError *error))error completed:(void (^)(void))completed {
    // 1. 創(chuàng)建訂閱者對(duì)象
    RACSubscriber *subscriber = [[self alloc] init];
    // 2. 保存Next block 、error block 、completed block
    subscriber->_next = [next copy];
    subscriber->_error = [error copy];
    subscriber->_completed = [completed copy];
    // 3. 返回訂閱者
    return subscriber;
}

// 點(diǎn)擊[self subscribe:o] 內(nèi)部實(shí)現(xiàn)
- (RACDisposable *)subscribe:(id<RACSubscriber>)subscriber {
    NSCParameterAssert(subscriber != nil);

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

    // 4. 這里判斷didSubcribe是 否為空
    // didSubcribe 對(duì)象就是signal 的block 對(duì)象
    if (self.didSubscribe != NULL) {
        RACDisposable *schedulingDisposable = [RACScheduler.subscriptionScheduler schedule:^{

            // 這里就在調(diào)用didSubscribe 方法，并且把剛傳入的 subscriber 調(diào)用出去
            // 5. 也就是說(shuō), 要執(zhí)行 signal對(duì)象創(chuàng)建方法的 block
            RACDisposable *innerDisposable = self.didSubscribe(subscriber);
            [disposable addDisposable:innerDisposable];
        }];

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

• 通過(guò)注釋5 可以知道, 接下來(lái)就會(huì)調(diào)用[subscriber sendNext:@10] 等操作, 這也就是信號(hào)的發(fā)送.
  ↓sendNext 源碼↓

- (void)sendNext:(id)value {
    @synchronized (self) {
        void (^nextBlock)(id) = [self.next copy];
        // 6. nextblock 不為空就把傳進(jìn)來(lái)傳value 原封不動(dòng)的調(diào)用出去, 而這個(gè)nextblock就是我們?cè)谟嗛喰盘?hào)的時(shí)候創(chuàng)建的那個(gè)subscriber 所保存的nextblock
        if (nextBlock == nil) return;

        nextBlock(value);
    }
}

• 通過(guò)注釋6 可以知道, 信號(hào)通過(guò)send 操作, 回調(diào)出來(lái), 進(jìn)行打印.

    [signal subscribeNext:^(id  _Nullable x) {
        // 打印 x
        NSLog(@"%@", x);
    }];

總結(jié):

所以RACSignal的處理流程就是

創(chuàng)建信號(hào)的block會(huì)在訂閱信號(hào)的時(shí)候調(diào)用
訂閱信號(hào)的block會(huì)在訂閱者發(fā)布信息的時(shí)候調(diào)用

.End