這樣好用的ReactiveCocoa，根本停不下來
我個人非常推崇ReactiveCocoa，它就像中國的太極，太極生兩儀，兩儀生四象，四象生八卦，八卦生萬物。ReactiveCocoa是一個高度抽象的編程框架，它真的很抽象，初看你不知道它是要干嘛的，等你用上了之后，就發(fā)現(xiàn)，有了它你是想干嘛就干嘛，編碼從未如此流暢。在此我不會講ReactiveCocoa的原理，因為不能講明白的才叫抽象。我也不會提及相關概念。我只是讓你看看我用著它是有多爽。
前戲
我個人非常推崇ReactiveCocoa，它就像中國的太極，太極生兩儀，兩儀生四象，四象生八卦，八卦生萬物。ReactiveCocoa是一個高度抽象的編程框架，它真的很抽象，初看你不知道它是要干嘛的，等你用上了之后，就發(fā)現(xiàn)，有了它你是想干嘛就干嘛，編碼從未如此流暢。
在此我不會講ReactiveCocoa的原理，因為不能講明白的才叫抽象。我也不會提及相關概念。我只是讓你看看我用著它是有多爽。
代碼的四十八手
察值
你別動，你一動我就知道。
- @weakify(self);
- [RACObserve(self, value) subscribeNext:^(NSString* x) {
- @strongify(self);
- NSLog(@"你動了");
- }];
單邊
你唱歌，我就跳舞。
textField的內(nèi)容長度隱射成BOOL值，綁定到confirmButton的enable屬性上面，當textField輸入內(nèi)容不為空的時候，confirmButton的enable = YES。
- RACSignal *signalA = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
- [subscriber sendNext:@"唱歌"];
- [subscriber sendCompleted];
- return nil;
- }];
- RAC(self, value) = [signalA map:^id(NSString* value) {
- if ([value isEqualToString:@"唱歌"]) {
- return @"跳舞";
- }
- return @"";
- }];
雙邊
你向西，他就向東，他向左，你就向右。
- RACChannelTerminal *channelA = RACChannelTo(self, valueA);
- RACChannelTerminal *channelB = RACChannelTo(self, valueB);
- [[channelA map:^id(NSString *value) {
- if ([value isEqualToString:@"西"]) {
- return @"東";
- }
- return value;
- }] subscribe:channelB];
- [[channelB map:^id(NSString *value) {
- if ([value isEqualToString:@"左"]) {
- return @"右";
- }
- return value;
- }] subscribe:channelA];
- [[RACObserve(self, valueA) filter:^BOOL(id value) {
- return value ? YES : NO;
- }] subscribeNext:^(NSString* x) {
- NSLog(@"你向%@", x);
- }];
- [[RACObserve(self, valueB) filter:^BOOL(id value) {
- return value ? YES : NO;
- }] subscribeNext:^(NSString* x) {
- NSLog(@"他向%@", x);
- }];
- self.valueA = @"西";
- self.valueB = @"左";
- 2015-08-15 20:14:46.544 Test[2440:99901] 你向西
- 2015-08-15 20:14:46.544 Test[2440:99901] 他向東
- 2015-08-15 20:14:46.545 Test[2440:99901] 他向左
- 2015-08-15 20:14:46.545 Test[2440:99901] 你向右
代理
你是程序員，你幫我寫個app吧。
- @protocol Programmer <NSObject>
- - (void)makeAnApp;
- @end
- RACSignal *ProgrammerSignal =
- [self rac_signalForSelector:@selector(makeAnApp)
- fromProtocol:@protocol(Programmer)];
- [ProgrammerSignal subscribeNext:^(RACTuple* x) {
- NSLog(@"花了一個月，app寫好了");
- }];
- [self makeAnApp];
- 2015-08-15 20:46:45.720 Test[2817:114564] 花了一個月，app寫好了
廣播
知道你的頻道，我就能聽到你了。
- [[[NSNotificationCenter defaultCenter] rac_addObserverForName:@"代碼之道頻道" object:nil] subscribeNext:^(NSNotification* x) {
- NSLog(@"技巧：%@", x.userInfo[@"技巧"]);
- }];
- [[NSNotificationCenter defaultCenter] postNotificationName:@"代碼之道頻道" object:nil userInfo:@{@"技巧":@"用心寫"}];
- 2015-08-15 20:41:15.786 Test[2734:111505] 技巧：用心寫
連接
生活是一個故事接一個故事。
- RACSignal *signalA = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
- [subscriber sendNext:@"我戀愛啦"];
- [subscriber sendCompleted];
- return nil;
- }];
- RACSignal *signalB = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
- [subscriber sendNext:@"我結(jié)婚啦"];
- [subscriber sendCompleted];
- return nil;
- }];
- [[signalA concat:signalB] subscribeNext:^(id x) {
- NSLog(@"%@",x);
- }];
- 2015-08-15 12:19:46.707 Test[1845:64122] 我戀愛啦
- 2015-08-15 12:19:46.707 Test[1845:64122] 我結(jié)婚啦
合并
污水都應該流入污水處理廠被處理。
- RACSignal *signalA = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
- [subscriber sendNext:@"紙廠污水"];
- return nil;
- }];
- RACSignal *signalB = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
- [subscriber sendNext:@"電鍍廠污水"];
- return nil;
- }];
- [[RACSignal merge:@[signalA, signalB]] subscribeNext:^(id x) {
- NSLog(@"處理%@",x);
- }];
- 2015-08-15 12:10:05.371 Test[1770:60147] 處理紙廠污水
- 2015-08-15 12:10:05.372 Test[1770:60147] 處理電鍍廠污水
組合
你是紅的，我是黃的，我們就是紅黃的，你是白的，我沒變，我們是白黃的。
- RACSignal *signalA = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
- [subscriber sendNext:@"紅"];
- [subscriber sendNext:@"白"];
- return nil;
- }];
- RACSignal *signalB = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
- [subscriber sendNext:@"白"];
- return nil;
- }];
- [[RACSignal combineLatest:@[signalA, signalB]] subscribeNext:^(RACTuple* x) {
- RACTupleUnpack(NSString *stringA, NSString *stringB) = x;
- NSLog(@"我們是%@%@的", stringA, stringB);
- }];
- 2015-08-15 12:14:19.837 Test[1808:62042] 我們就是紅黃的
- 2015-08-15 12:14:19.837 Test[1808:62042] 我們是白黃的
壓縮
你是紅的，我是黃的，我們就是紅黃的，你是白的，我沒變，哦，那就等我變了再說吧。
- RACSignal *signalA = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
- [subscriber sendNext:@"紅"];
- [subscriber sendNext:@"白"];
- return nil;
- }];
- RACSignal *signalB = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
- [subscriber sendNext:@"白"];
- return nil;
- }];
- [[signalA zipWith:signalB] subscribeNext:^(RACTuple* x) {
- RACTupleUnpack(NSString *stringA, NSString *stringB) = x;
- NSLog(@"我們是%@%@的", stringA, stringB);
- }];
- 2015-08-15 20:34:24.274 Test[2660:108483] 我們是紅白的
映射
我可以點石成金。
- RACSignal *signal = [[RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
- [subscriber sendNext:@"石"];
- return nil;
- }] map:^id(NSString* value) {
- if ([value isEqualToString:@"石"]) {
- return @"金";
- }
- return value;
- }];
- [signal subscribeNext:^(id x) {
- NSLog(@"%@", x);
- }];
- 2015-08-16 20:00:12.853 Test[740:15871] 金
歸約
糖加水變成糖水。
- RACSignal *sugarSignal = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
- [subscriber sendNext:@"糖"];
- return nil;
- }];
- RACSignal *waterSignal = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
- [subscriber sendNext:@"水"];
- return nil;
- }];
- [[RACSignal combineLatest:@[sugarSignal, waterSignal] reduce:^id (NSString* sugar, NSString*water){
- return [sugar stringByAppendingString:water];
- }] subscribeNext:^(id x) {
- NSLog(@"%@", x);
- }];
- 2015-08-16 20:07:00.356 Test[807:19177] 糖水
過濾
未滿十八歲，禁止進入。
- [[[RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
- [subscriber sendNext:@(15)];
- [subscriber sendNext:@(17)];
- [subscriber sendNext:@(21)];
- [subscriber sendNext:@(14)];
- [subscriber sendNext:@(30)];
- return nil;
- }] filter:^BOOL(NSNumber* value) {
- return value.integerValue >= 18;
- }] subscribeNext:^(id x) {
- NSLog(@"%@", x);
- }];
- 2015-08-16 20:11:20.071 Test[860:21214] 21
- 2015-08-16 20:11:20.071 Test[860:21214] 30
扁平
打蛋液，煎雞蛋，上盤。
- [[[[RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
- NSLog(@"打蛋液");
- [subscriber sendNext:@"蛋液"];
- [subscriber sendCompleted];
- return nil;
- }] flattenMap:^RACStream *(NSString* value) {
- return [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
- NSLog(@"把%@倒進鍋里面煎",value);
- [subscriber sendNext:@"煎蛋"];
- [subscriber sendCompleted];
- return nil;
- }];
- }] flattenMap:^RACStream *(NSString* value) {
- return [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
- NSLog(@"把%@裝到盤里", value);
- [subscriber sendNext:@"上菜"];
- [subscriber sendCompleted];
- return nil;
- }];
- }] subscribeNext:^(id x) {
- NSLog(@"%@", x);
- }];
- 2015-08-16 20:39:34.786 Test[1226:34386] 打蛋液
- 2015-08-16 20:39:34.787 Test[1226:34386] 把蛋液倒進鍋里面煎
- 2015-08-16 20:39:34.787 Test[1226:34386] 把煎蛋裝到盤里
- 2015-08-16 20:39:34.787 Test[1226:34386] 上菜
秩序
把大象塞進冰箱只需要三步：打開冰箱門，把大象塞進冰箱，關上冰箱門。
- [[[[RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
- NSLog(@"打開冰箱門");
- [subscriber sendCompleted];
- return nil;
- }] then:^RACSignal *{
- return [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
- NSLog(@"把大象塞進冰箱");
- [subscriber sendCompleted];
- return nil;
- }];
- }] then:^RACSignal *{
- return [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
- NSLog(@"關上冰箱門");
- [subscriber sendCompleted];
- return nil;
- }];
- }] subscribeCompleted:^{
- NSLog(@"把大象塞進冰箱了");
- }];
- 2015-08-16 20:45:27.724 Test[1334:37870] 打開冰箱門
- 2015-08-16 20:45:27.725 Test[1334:37870] 把大象塞進冰箱
- 2015-08-16 20:45:27.725 Test[1334:37870] 關上冰箱門
- 2015-08-16 20:45:27.726 Test[1334:37870] 把大象塞進冰箱了
命令
我命令你馬上投降。
- RACCommand *aCommand = [[RACCommand alloc] initWithSignalBlock:^RACSignal *(id input) {
- return [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
- NSLog(@"我投降了");
- [subscriber sendCompleted];
- return nil;
- }];
- }];
- [aCommand execute:nil];
- 2015-08-16 20:54:32.492 Test[1450:41849] 我投降了
延遲
等等我，我還有10秒鐘就到了。
- [[[RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
- NSLog(@"等等我，我還有10秒鐘就到了");
- [subscriber sendNext:nil];
- [subscriber sendCompleted];
- return nil;
- }] delay:10] subscribeNext:^(id x) {
- NSLog(@"我到了");
- }];
- 2015-08-16 21:00:57.622 Test[1619:45924] 等等我，我還有10秒鐘就到了
- 2015-08-16 21:01:07.624 Test[1619:45924] 我到了
重放
一次制作，多次觀看。
- RACSignal *replaySignal = [[RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
- NSLog(@"大導演拍了一部電影《我的男票是程序員》");
- [subscriber sendNext:@"《我的男票是程序員》"];
- return nil;
- }] replay];
- [replaySignal subscribeNext:^(id x) {
- NSLog(@"小明看了%@", x);
- }];
- [replaySignal subscribeNext:^(id x) {
- NSLog(@"小紅也看了%@", x);
- }];
- 2015-08-16 21:18:38.002 Test[1854:54712] 大導演拍了一部電影《我的男票是程序員》
- 2015-08-16 21:18:38.004 Test[1854:54712] 小明看了《我的男票是程序員》
- 2015-08-16 21:18:38.004 Test[1854:54712] 小紅也看了《我的男票是程序員》
定時
每隔8個小時服一次藥。
- [[RACSignal interval:60*60*8 onScheduler:[RACScheduler mainThreadScheduler]] subscribeNext:^(id x) {
- NSLog(@"吃藥");
- }];
超時
等了你一個小時了，你還沒來，我走了。
- [[[RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
- [[[RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
- NSLog(@"我快到了");
- [subscriber sendNext:nil];
- [subscriber sendCompleted];
- return nil;
- }] delay:60*70] subscribeNext:^(id x) {
- [subscriber sendNext:nil];
- [subscriber sendCompleted];
- }];
- return nil;
- }] timeout:60*60 onScheduler:[RACScheduler mainThreadScheduler]] subscribeError:^(NSError *error) {
- NSLog(@"等了你一個小時了，你還沒來，我走了");
- }];
- 2015-08-16 21:40:09.068 Test[2041:64720] 我快到了
- 2015-08-16 22:40:10.048 Test[2041:64720] 等了你一個小時了，你還沒來，我走了
重試
成功之前可能需要數(shù)百次失敗。
- __block int failedCount = 0;
- [[[RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
- if (failedCount < 100) {
- failedCount++;
- NSLog(@"我失敗了");
- [subscriber sendError:nil];
- }else{
- NSLog(@"經(jīng)歷了數(shù)百次失敗后");
- [subscriber sendNext:nil];
- }
- return nil;
- }] retry] subscribeNext:^(id x) {
- NSLog(@"終于成功了");
- }];
- 2015-08-16 21:59:07.159 Test[2411:77080] 我失敗了
- 2015-08-16 21:59:07.159 Test[2411:77080] 我失敗了
- 2015-08-16 21:59:07.159 Test[2411:77080] 我失敗了
- 2015-08-16 21:59:07.159 Test[2411:77080] 我失敗了
- 2015-08-16 21:59:07.160 Test[2411:77080] 我失敗了
- 2015-08-16 21:59:07.160 Test[2411:77080] 我失敗了
- 2015-08-16 21:59:07.161 Test[2411:77080] 我失敗了
- 2015-08-16 21:59:07.162 Test[2411:77080] 我失敗了
- ...
- 2015-08-16 21:59:07.162 Test[2411:77080] 我失敗了
- 2015-08-16 21:59:07.163 Test[2411:77080] 我失敗了
- 2015-08-16 21:59:07.163 Test[2411:77080] 我失敗了
- 2015-08-16 21:59:07.163 Test[2411:77080] 我失敗了
- 2015-08-16 21:59:07.164 Test[2411:77080] 我失敗了
- 2015-08-16 21:59:07.164 Test[2411:77080] 我失敗了
- 2015-08-16 21:59:07.164 Test[2411:77080] 我失敗了
- 2015-08-16 21:59:07.165 Test[2411:77080] 經(jīng)歷了數(shù)百次失敗后
- 2015-08-16 21:59:07.165 Test[2411:77080] 終于成功了
節(jié)流
不好意思，這里一秒鐘只能通過一個人。
- [[[RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
- [subscriber sendNext:@"旅客A"];
- dispatch_after(dispatch_time(DISPATCH_TIME_NOW, (int64_t)(1 * NSEC_PER_SEC)), dispatch_get_main_queue(), ^{
- [subscriber sendNext:@"旅客B"];
- });
- dispatch_after(dispatch_time(DISPATCH_TIME_NOW, (int64_t)(2 * NSEC_PER_SEC)), dispatch_get_main_queue(), ^{
- [subscriber sendNext:@"旅客C"];
- [subscriber sendNext:@"旅客D"];
- [subscriber sendNext:@"旅客E"];
- });
- dispatch_after(dispatch_time(DISPATCH_TIME_NOW, (int64_t)(3 * NSEC_PER_SEC)), dispatch_get_main_queue(), ^{
- [subscriber sendNext:@"旅客F"];
- });
- return nil;
- }] throttle:1] subscribeNext:^(id x) {
- NSLog(@"%@通過了",x);
- }];
- 2015-08-16 22:08:45.677 Test[2618:83764] 旅客A
- 2015-08-16 22:08:46.737 Test[2618:83764] 旅客B
- 2015-08-16 22:08:47.822 Test[2618:83764] 旅客E
- 2015-08-16 22:08:48.920 Test[2618:83764] 旅客F
條件
直到世界的盡頭才能把我們分開。
- [[[RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
- [[RACSignal interval:1 onScheduler:[RACScheduler mainThreadScheduler]] subscribeNext:^(id x) {
- [subscriber sendNext:@"直到世界的盡頭才能把我們分開"];
- }];
- return nil;
- }] takeUntil:[RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
- dispatch_after(dispatch_time(DISPATCH_TIME_NOW, (int64_t)(5 * NSEC_PER_SEC)), dispatch_get_main_queue(), ^{
- NSLog(@"世界的盡頭到了");
- [subscriber sendNext:@"世界的盡頭到了"];
- });
- return nil;
- }]] subscribeNext:^(id x) {
- NSLog(@"%@", x);
- }];
- 2015-08-16 22:17:22.648 Test[2766:88737] 直到世界的盡頭才能把我們分開
- 2015-08-16 22:17:23.648 Test[2766:88737] 直到世界的盡頭才能把我們分開
- 2015-08-16 22:17:24.645 Test[2766:88737] 直到世界的盡頭才能把我們分開
- 2015-08-16 22:17:25.648 Test[2766:88737] 直到世界的盡頭才能把我們分開
- 2015-08-16 22:17:26.644 Test[2766:88737] 直到世界的盡頭才能把我們分開
- 2015-08-16 22:17:26.645 Test[2766:88737] 世界的盡頭到了
完事
ReactiveCocoa是如此優(yōu)雅，一旦使用，根本停不下來，上面也只是它的一角冰山，但愿我能挑起你的興趣
責任編輯：倪明
來源：
空之境界投稿
