ReactiveCocoa 初识（一）

    入职有一段时间了，没有开发任务，白天就看看博客写写自己的东西，晚上看世界杯，简直不要太爽，就是天台有点挤了(╯3╰)。
    最近在学习ReactiveCocoa，项目导入ReactiveObjC开干。

RACSignal
    RACSignal是RAC核心的类，使用的时候先创建信号，订阅信号，在创建信号的block里面发送信号。

- (void)RACSignal
{
    //1 创建信号
    RACSignal * signal = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        
        //3 发送信号
        [subscriber sendNext:@"发送信号"];
        
        return [RACDisposable disposableWithBlock:^{
            NSLog(@"取消订阅");
        }];
//        return nil;
    }];
    
    //2 订阅信号
    RACDisposable * disposable = [signal subscribeNext:^(id  _Nullable x) {
        NSLog(@"%@",x);
    }];
    
    //4 取消订阅
    [disposable dispose];
}

RACSubject
    RACSubject是继承自RACSignal，同时也遵循RACSubscriber协议。所以RACSubject既可以订阅信号，也能发送信号。使用方法也是先订阅后发送。它和RACReplaySubject的区别是，RACReplaySubject可以先发送后订阅。

- (void)RACSubject
{    
    //1 创建信号
    RACSubject * subject = [RACSubject subject];
    
    //2 订阅信号
    [subject subscribeNext:^(id  _Nullable x) {
        NSLog(@"%@",x);
    }];
    
    //3 发送信号
    [subject sendNext:@"发送信号"];
}

RACSequence
    RACSequence一般用于遍历数组和字典等容器类，RAC扩展了一种数据类型Tuple元祖，接触过Swift的一定不会陌生。

- (void)RACSequence
{
    //遍历
    
    NSArray * array = @[@"1",@"2",@"3",@"3",@"5"];
    [array.rac_sequence.signal subscribeNext:^(id  _Nullable x) {
        NSLog(@"%@",x);
    }];
    
    //元祖
    RACTuple * tuple = RACTuplePack(array);
    NSLog(@"%@",tuple[0]);
    NSLog(@"%@",[tuple first]);
    NSLog(@"%@",[tuple last]);
    
    NSDictionary * dict = @{@"key1":@"value1",@"key2":@"value2"};
    [dict.rac_sequence.signal subscribeNext:^(id  _Nullable x) {
        RACTupleUnpack(NSString * key,NSString * value) = x;
        NSLog(@"%@  %@",key,value);
    }];
    
    //替换数组的元素 生成新的数组 单个操作
    NSArray * newArray1 = [[array.rac_sequence map:^id _Nullable(id  _Nullable value) {
        return @"0";
    }] array];
    NSLog(@"%@",newArray1);
    
    //替换数组的元素 生成新的数组 全部操作
    NSArray * newArray2 = [[array.rac_sequence mapReplace:@"1"] array];
    NSLog(@"%@",newArray2);
}

RACMulticastConnection
    ReactiveCocoa中信号默认都是冷的，每次有新的订阅者订阅信号的时候都会执行信号创建时传入的block。举个例子，把一个网络请求的结果设置为信号，多个UI订阅了这个信号，每次订阅的时候，都会进行一次网络请求。

RACSignal * signal = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        /*网络请求*/
        [subscriber sendNext:@"发送信号"];
        return nil;
    }];
    
    [signal subscribeNext:^(id  _Nullable x) {
        NSLog(@"%@",x);
    }];
    
    [signal subscribeNext:^(id  _Nullable x) {
        NSLog(@"%@",x);
    }];
    
    [signal subscribeNext:^(id  _Nullable x) {
        NSLog(@"%@",x);
    }];

    为了避免这一情况，使用RACMulticastConnection，创建链接类，将订阅者连接起来，把信号源变成热信号。

- (void)RACMulticastConnection
{
    //多个订阅者 只发一个信号
    RACSignal * signal = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        [subscriber sendNext:@"发送信号"];
        return nil;
    }];
    
    //创建链接类
    RACMulticastConnection * connection = [signal publish];
    
    [connection.signal subscribeNext:^(id  _Nullable x) {
        NSLog(@"%@",x);
    }];
    
    [connection.signal subscribeNext:^(id  _Nullable x) {
        NSLog(@"%@",x);
    }];
    
    [connection.signal subscribeNext:^(id  _Nullable x) {
        NSLog(@"%@",x);
    }];
    
    //连接 把信号源变为热信号
    [connection connect];
}

merge
    信号的合并

- (void)merge
{
    RACSubject * subject1 = [RACSubject subject];
    RACSubject * subject2 = [RACSubject subject];
    RACSubject * subject3 = [RACSubject subject];
    
    [[RACSignal merge:@[subject1,subject2,subject3]] subscribeNext:^(id  _Nullable x) {
        NSLog(@"%@",x);
    }];
    
    [subject1 sendNext:@"subject1"];
    [subject2 sendNext:@"subject2"];
    [subject3 sendNext:@"subject3"];
}

group
    类似于GCD的任务组，完成多个任务后才能执行某个方法

- (void)group
{
    RACSignal * signalA = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        /*网络请求1*/
        [subscriber sendNext:@"请求1完成"];
        return nil;
    }];
    
    RACSignal * signalB = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        /*网络请求2*/
        [subscriber sendNext:@"请求2完成"];
        return nil;
    }];
    
    [self rac_liftSelector:@selector(dependSignalA:WithSignalB:) withSignalsFromArray:@[signalA,signalB]];
}

- (void)dependSignalA:(NSString *)str1 WithSignalB:(NSString *)str2
{
    
}

Notification && KVO
    RAC来替换Notification和KVO的

- (void)Notification
{
    //不用写removeObserver
    [[[NSNotificationCenter defaultCenter] rac_addObserverForName:@"NotificationName" object:nil] subscribeNext:^(NSNotification * _Nullable x) {
        NSLog(@"%@",x);
    }];
}

- (void)KVO
{
    [[self.view rac_valuesForKeyPath:@"color" observer:self] subscribeNext:^(id  _Nullable x) {
        NSLog(@"%@",x);
    }];
}

Timer
    RAC实现一个Timer的功能

- (void)Timer
{
    RACDisposable * disposable = [[RACSignal interval:1.f onScheduler:[RACScheduler mainThreadScheduler]] subscribeNext:^(NSDate * _Nullable x) {
        //当前时间
        NSLog(@"%@",x);
        
        [disposable dispose];
    }];
}

UI
    再来看看RAC在UI上的一些应用

- (void)UI
{
    UITextField * tf = [UITextField new];
    UITextField * tf2 = [UITextField new];
    UIButton * btn = [UIButton new];
    
    [[tf rac_textSignal] subscribeNext:^(NSString * _Nullable x) {
        NSLog(@"%@",x);
    }];
    
    //filter 和 ignore
    [[[tf2.rac_textSignal filter:^BOOL(NSString * _Nullable value) {
        return value.length > 6;
    }] ignore:@"666"] subscribeNext:^(NSString * _Nullable x) {
        NSLog(@"%@",x);
    }];
    
    //响应事件
    [[btn rac_signalForControlEvents:UIControlEventTouchUpInside] subscribeNext:^(__kindof UIControl * _Nullable x) {
        NSLog(@"%@",x);
    }];
    
    //两个输入框长度大于3的时候 按钮才可以点击
    RAC(btn,enabled) = [RACSignal combineLatest:@[tf.rac_textSignal,tf2.rac_textSignal] reduce:^id (NSString * str1, NSString * str2){
        return @(str1.length > 3 && str2.length > 3);
    }];
}

    ReactiveCocoa是个响应式编程框架，在iOS中没有接触过类似的代码。不过之前有接触过AngularJS，对里面ng-Model指令,单向绑定、双向绑定有一定的了解。下篇会重点理解RACCommand，结合一个登录的Demo来实践。
    代码： ReactiveObjCDemo

最后编辑于 ：
©著作权归作者所有,转载或内容合作请联系作者
  • 人面猴
    序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
    沈念sama阅读 213,047评论 6赞 492
  • 死咒
    序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
    沈念sama阅读 90,807评论 3赞 386
  • 救了他两次的神仙让他今天三更去死
    文/潘晓璐 我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
    开封第一讲书人阅读 158,501评论 0赞 348
  • 道士缉凶录：失踪的卖姜人
    文/不坏的土叔 我叫张陵，是天一观的道长。 经常有香客问我，道长，这世上最难降的妖魔是什么？ 我笑而不...
    开封第一讲书人阅读 56,839评论 1赞 285
  • 港岛之恋（遗憾婚礼）
    正文 为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
    茶点故事阅读 65,951评论 6赞 386
  • 恶毒庶女顶嫁案：这布局不是一般人想出来的
    文/花漫 我一把揭开白布。 她就那样静静地躺着，像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上，一...
    开封第一讲书人阅读 50,117评论 1赞 291
  • 城市分裂传说
    那天，我揣着相机与录音，去河边找鬼。 笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。 我是一名探鬼主播，决...
    沈念sama阅读 39,188评论 3赞 412
  • 双鸳鸯连环套：你想象不到人心有多黑
    文/苍兰香墨 我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
    开封第一讲书人阅读 37,929评论 0赞 268
  • 万荣杀人案实录
    序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
    沈念sama阅读 44,372评论 1赞 303
  • 护林员之死
    正文 独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 36,679评论 2赞 327
  • 白月光启示录
    正文 我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 38,837评论 1赞 341
  • 活死人
    序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
    沈念sama阅读 34,536评论 4赞 335
  • 日本核电站爆炸内幕
    正文 年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
    茶点故事阅读 40,168评论 3赞 317
  • 男人毒药：我在死后第九天来索命
    文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 30,886评论 0赞 21
  • 一桩弑父案，背后竟有这般阴谋
    文/苍兰香墨 我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,129评论 1赞 267
  • 情欲美人皮
    我被黑心中介骗来泰国打工， 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。 一个月前我还...
    沈念sama阅读 46,665评论 2赞 362
  • 代替公主和亲
    正文 我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
    茶点故事阅读 43,739评论 2赞 351