文章系列
《ReactiveCocoa 概述》
《RACSignal》
《RACDisposable》
《RACSubject箱叁、RACReplaySubject(內(nèi)附冷信號和熱信號的區(qū)別)》
《集合RACTuple、RACSequence》
《RAC 中的通知、代理践磅、KVO, 基本事件杏瞻、方法的監(jiān)聽》
《rac_liftSelector》
《RACMulticastConnection》
《RACCommand》
《RAC - 核心方法bind》
《RAC - 定時器》
《RACScheduler》
《RAC - 點擊獲取驗證碼 demo》
《RAC - 映射(Map & flattenMap)》
《RAC信號操作解釋合集》
《RAC - 信號的生命周期》
RACSignal: 信號類, 本身不具備發(fā)送信號的能力, 當(dāng)被訂閱后, 用于傳遞改變的數(shù)據(jù), 可傳遞以下三種狀態(tài)：
- sendNext(id)：可理解為傳遞正確數(shù)據(jù)平道，告訴訂閱者進(jìn)行下一步處理
- sendError：傳遞的數(shù)據(jù)錯誤辅髓，告訴訂閱者錯誤處理
- sendCompleted：告訴訂閱者已完成
-
流程圖:signal.png
代碼分析 (
注釋很詳細(xì)!!!)
- (void)signalTest {
/* 1. 創(chuàng)建信號 signal
- 通過 createSignal: 方法創(chuàng)建,其參數(shù)為一個返回值位RACDisposable 類型的block (didSubcribe)
*/
RACSignal *signal = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber> _Nonnull subscriber) {
// 2. 通過block 傳入的訂閱者subscriber 來發(fā)送信息
[subscriber sendNext:@10];
// sendError浪感、sendCompleted 二者只能發(fā)送其一, 就代表結(jié)束了.
[subscriber sendError:[NSError errorWithDomain:@"錯誤" code:1001 userInfo:nil]];
[subscriber sendCompleted];
// 這里需要返回一個RACDisposable 類型的對象, 用于提前結(jié)束訂閱等操作, 一般無特殊需求, 返回nil 即可.
return nil;
}];
/* 3. 訂閱者 (subscriber)
- subscribeNext + error + completed 組合起來就是訂閱者
- 一旦訂閱者訂閱了信號消息, 就會執(zhí)行上面的didSubcribe 的block.
*/
[signal subscribeNext:^(id _Nullable x) {
NSLog(@"%@", x);
} error:^(NSError * _Nullable error) {
NSLog(@"ERROR=%@", error);
} completed:^{
NSLog(@"完成");
}];
}
- ↓分析 [RACSignal createSignal:]內(nèi)部實現(xiàn)↓:
// 第1次點擊方法跳轉(zhuǎn)內(nèi)部實現(xiàn):
+ (RACSignal *)createSignal:(RACDisposable * (^)(id<RACSubscriber> subscriber))didSubscribe {
// 內(nèi)部創(chuàng)建RACDynamicSignal 信號, 并將外部block 繼續(xù)傳遞
return [RACDynamicSignal createSignal:didSubscribe];
}
// 第2次點擊方法跳轉(zhuǎn)內(nèi)部實現(xiàn):
+ (RACSignal *)createSignal:(RACDisposable * (^)(id<RACSubscriber> subscriber))didSubscribe {
// 1. 創(chuàng)建 RACDynamicSignal對象
// 2. 保存以參數(shù)形式傳遞進(jìn)來的 block
// 3. 返回 RACDynamicSignal 對象
RACDynamicSignal *signal = [[self alloc] init];
signal->_didSubscribe = [didSubscribe copy];
return [signal setNameWithFormat:@"+createSignal:"];
}
- ↓分析 訂閱者 訂閱過程的實現(xiàn)(
源碼邏輯分析, 幫助理解)↓:
// 開始訂閱
[signal subscribeNext:^(id _Nullable x) {
// 訂閱信號之后得到帶有一個參數(shù)為 x的 block
NSLog(@"%@", x);
}];
// 點擊 [signal subscribeNext:]內(nèi)部實現(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];
}
// 點擊[RACSubscriber subscriberWithNext:] 內(nèi)部實現(xiàn)
+ (instancetype)subscriberWithNext:(void (^)(id x))next error:(void (^)(NSError *error))error completed:(void (^)(void))completed {
// 1. 創(chuàng)建訂閱者對象
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;
}
// 點擊[self subscribe:o] 內(nèi)部實現(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 對象就是signal 的block 對象
if (self.didSubscribe != NULL) {
RACDisposable *schedulingDisposable = [RACScheduler.subscriptionScheduler schedule:^{
// 這里就在調(diào)用didSubscribe 方法，并且把剛傳入的 subscriber 調(diào)用出去
// 5. 也就是說, 要執(zhí)行 signal對象創(chuàng)建方法的 block
RACDisposable *innerDisposable = self.didSubscribe(subscriber);
[disposable addDisposable:innerDisposable];
}];
[disposable addDisposable:schedulingDisposable];
}
return disposable;
}
- 通過注釋5 可以知道, 接下來就會調(diào)用[subscriber sendNext:@10] 等操作, 這也就是信號的發(fā)送.
↓sendNext 源碼↓
- (void)sendNext:(id)value {
@synchronized (self) {
void (^nextBlock)(id) = [self.next copy];
// 6. nextblock 不為空就把傳進(jìn)來傳value 原封不動的調(diào)用出去, 而這個nextblock就是我們在訂閱信號的時候創(chuàng)建的那個subscriber 所保存的nextblock
if (nextBlock == nil) return;
nextBlock(value);
}
}
- 通過注釋6 可以知道, 信號通過send 操作, 回調(diào)出來, 進(jìn)行打印.
[signal subscribeNext:^(id _Nullable x) {
// 打印 x
NSLog(@"%@", x);
}];
總結(jié):
所以RACSignal的處理流程就是
創(chuàng)建信號的block會在訂閱信號的時候調(diào)用
訂閱信號的block會在訂閱者發(fā)布信息的時候調(diào)用
.End
