iOS RAC-进阶用法

map

    [[self.textField.rac_textSignal flattenMap:^__kindof RACSignal * _Nullable(NSString * _Nullable value) {
        NSLog(@"%@",value);
        //不单纯的把文字内容返回,而是在一定的函数基础上返回
        return [RACReturnSignal return:[NSString stringWithFormat:@"010-%@",value]];
    }] subscribeNext:^(id  _Nullable x) {
        NSLog(@"subscribeNext %@",x);
    }];

filter 过滤

    [[self.textField.rac_textSignal filter:^BOOL(NSString * _Nullable value) {
        //做过滤条件
       @strongify(self)
        if (self.textField.text.length > 6) {
            self.textField.text = [self.textField.text substringToIndex:6];
        }
        return value.length < 6;
    }] subscribeNext:^(NSString * _Nullable x) {
        //逻辑区域
        NSLog(@"subscribeNext %@",x);
    }];

combine

    @weakify(self)
    RACSignal *signalA = self.textField.rac_textSignal;
    RACSignal *singalB = self.passwordField.rac_textSignal;
    [[RACSignal combineLatest:@[signalA,singalB] reduce:^id(NSString *account,NSString *password){
        return @(account.length > 0 && password.length > 0);
    }] subscribeNext:^(NSNumber  *x) {
        @strongify(self)
        NSLog(@"subscribeNext %@",x);
        self.button.enabled = x.integerValue;
    }];

takeUntil

    //takeUntil subjectA可以正常发送信号直到subjectB发送信号或者subjectB发送sendCompleted,就不能接受信号的内容了
    RACSubject *subjectA = [RACSubject subject];
    RACSubject *subjectB = [RACSubject subject];
    [[subjectA takeUntil:subjectB] subscribeNext:^(id  _Nullable x) {
        NSLog(@"%@",x);
    }];
    [subjectA sendNext:@"A"];
    [subjectA sendNext:@"B"];
    
    //    [subjectB sendNext:@"C"];
    [subjectB sendCompleted];
    [subjectA sendNext:@"D"];//不打印

retry

    // retry重试 ：只要失败，就会重新执行创建信号中的block,直到成功.
    __block int i = 0;
    [[[RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
        if (i == 10) {
            [subscriber sendNext:@1];
        }else{
            NSLog(@"接收到错误");
            [subscriber sendError:nil];
        }
        i++;
        return nil;
    }] retry] subscribeNext:^(id x) {
        NSLog(@"%@",x);
    } error:^(NSError *error) {
        
    }];

replay

    // `replay`重放：当一个信号被多次订阅,反复播放内容
    RACSignal *signal = [[RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
        [subscriber sendNext:@1];
        [subscriber sendNext:@2];
        return nil;
    }] replay];
    [signal subscribeNext:^(id x) {
        NSLog(@"第一个订阅者%@",x);
    }];
    [signal subscribeNext:^(id x) {
        NSLog(@"第二个订阅者%@",x);
    }];
    [signal subscribeNext:^(id x) {
        NSLog(@"第三个订阅者%@",x);
    }];

2019-01-31 17:29:57.448724+0800 RAC-OC_01[15855:609229] 第一个订阅者2
2019-01-31 17:29:57.448857+0800 RAC-OC_01[15855:609229] 第二个订阅者1
2019-01-31 17:29:57.448937+0800 RAC-OC_01[15855:609229] 第二个订阅者2
2019-01-31 17:29:57.449038+0800 RAC-OC_01[15855:609229] 第三个订阅者1
2019-01-31 17:29:57.449115+0800 RAC-OC_01[15855:609229] 第三个订阅者2

timeOut

    RACSignal *signal = [[RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
        return nil;
        
    }] timeout:1 onScheduler:[RACScheduler currentScheduler]];
    
    
    [signal subscribeNext:^(id  _Nullable x) {
        
        NSLog(@"%@",x);
        
    } error:^(NSError * _Nullable error) {
        NSLog(@"%@",error);
        
    }];

switchToLatest

    RACSubject *signalOfSignals = [RACSubject subject];
    RACSubject *signal = [RACSubject subject];
    //获取信号中的号最近发出的信号,订阅最近发出的信号
    //注意siwtchToLatest:只能用于信号中的信号
    [[signalOfSignals switchToLatest] subscribeNext:^(id  _Nullable x) {
        NSLog(@"%@",x);
    }];
    [signalOfSignals sendNext:signal];
    [signal sendNext:@"1"];
    [signal sendNext:@"2"];
    [signal sendCompleted];
    [signal sendNext:@"3"];

2019-01-31 17:30:53.760808+0800 RAC-OC_01[15885:611621] 1
2019-01-31 17:30:53.760955+0800 RAC-OC_01[15885:611621] 2

take和takeLast

    //takeLast 和take的用法基本一样,但是是取最后的设定的那几个在值,如下去的是最后发送的两个值:2,3
    //注意:takeLast 一定要用sendCompleted,告诉他发送完成了,这样才能取到最后的几个值
    RACSubject *subject = [RACSubject subject];
    [[subject takeLast:2] subscribeNext:^(id  _Nullable x) {
        NSLog(@"takeLast%@",x);
    }];
    [[subject take:1] subscribeNext:^(id  _Nullable x) {
        NSLog(@"take %@",x);
    }];
    [subject sendNext:@"1"];
    [subject sendNext:@"2"];
    [subject sendNext:@"3"];
    [subject sendCompleted];

2019-01-31 17:31:39.809828+0800 RAC-OC_01[15913:613819] take 1
2019-01-31 17:31:39.810365+0800 RAC-OC_01[15913:613819] takeLast2
2019-01-31 17:31:39.810454+0800 RAC-OC_01[15913:613819] takeLast3

skip

     // 表示输入第一次，不会被监听到，跳过第一次发出的信号
    [[self.textField.rac_textSignal skip:1] subscribeNext:^(NSString * _Nullable x) {
        NSLog(@"subscribeNext skip %@",x);
    }];
    [self.textField.rac_textSignal  subscribeNext:^(NSString * _Nullable x) {
        NSLog(@"subscribeNext  %@",x);
    }];

distinctUntilChanged

    //distinctUntilChanged 当上一次的值和当前的值有明显的变化就会发出信号,否则会被忽略掉
    //在开发中，刷新UI经常使用，只有两次数据不一样才需要刷新
    RACSubject *subject = [RACSubject subject];
    [[subject distinctUntilChanged] subscribeNext:^(id  _Nullable x) {
        NSLog(@"%@",x);
    }];
    [subject sendNext:@"1"];
    [subject sendNext:@"1"];
    [subject sendNext:@"2"];
    [subject sendCompleted];
    
    [[self.textField.rac_textSignal distinctUntilChanged] subscribeNext:^(NSString * _Nullable x) {
        NSLog(@"textField change %@",x);
    }];

2019-01-31 17:32:56.801033+0800 RAC-OC_01[15940:616672] 1
2019-01-31 17:32:56.801313+0800 RAC-OC_01[15940:616672] 2
2019-01-31 17:32:56.803264+0800 RAC-OC_01[15940:616672] textField change

ignore

    // 内部调用filter过滤，忽略掉ignore的值
    [[self.textField.rac_textSignal ignore:@"1"] subscribeNext:^(NSString * _Nullable x) {
        NSLog(@"%@",x);
    }];

reduce

    //reduce`聚合:用于信号发出的内容是元组，把信号发出元组的值聚合成一个值
    
    //其中Aggregation(聚合关系)、Composition(合成关系)属于Association(关联关系)，是特殊的Association关联关系。
    //可以延伸组合关系,聚合关系
    //组合关系 A-B组合成了C C包含所有的A和B
    //聚合关系 聚合关系是整体和个体的关系(是强的关联关系) 公司与个人,但是个人不完全属于公司
    
    // 聚合常见的用法，（先组合在聚合）:combineLatest:(id<NSFastEnumeration>)signals reduce:(id (^)())reduceBlock
    // reduce中的block简介:
    // reduceblcok中的参数，有多少信号组合，reduceblcok就有多少参数，每个参数就是之前信号发出的内容
    // reduceblcok的返回值：聚合信号之后的内容。
    RACSignal *signalA = self.textField.rac_textSignal;
    RACSignal *signalB = [self.button rac_signalForControlEvents:UIControlEventTouchUpInside];
    RACSignal *reduceSignal = [RACSignal combineLatest:@[signalA,signalB] reduce:^id (NSString *textFieldText,UIButton *value2 ){
        return [NSString stringWithFormat:@"reduce == %@ %@",textFieldText,value2];
    }];
    [reduceSignal subscribeNext:^(id  _Nullable x) {
        NSLog(@"subscribeNext %@",x);
    }];

zip

    // 底层实现:
    // 1.定义压缩信号，内部就会自动订阅signalA，signalB
    // 2.每当signalA或者signalB发出信号，就会判断signalA，signalB有没有发出个信号，有就会把最近发出的信号都包装成元组发出。
    RACSignal *signalA = self.textField.rac_textSignal;
    RACSignal *signalB = [self.button rac_signalForControlEvents:UIControlEventTouchUpInside];
    // 合并信号,任何一个信号发送数据，都能监听到.
    RACSignal *zipSignal = [signalA zipWith:signalB];
    [zipSignal subscribeNext:^(id  _Nullable x) {
        NSLog(@"%@",x);
    }];

combineLatestWith

    //将多个信号合并起来，并且拿到各个信号的最新的值,必须每个合并的signal至少都有过一次sendNext，才会触发合并的信号。
    
    RACSignal *signalA = self.textField.rac_textSignal;
    RACSignal *signalB = [self.button  rac_signalForControlEvents:UIControlEventTouchUpInside];
    
    // 合并信号,任何一个信号发送数据，都能监听到.
    RACSignal *comSignal = [signalA combineLatestWith:signalB];
    
    [comSignal subscribeNext:^(id x) {
        NSLog(@"subscribeNext %@",x[0]);
    }];
    // 底层实现：
    // 1.当组合信号被订阅，内部会自动订阅signalA，signalB,必须两个信号都发出内容，才会被触发。
    // 2.并且把两个信号组合成元组发出。

区别于zipWith zipWith两个信号都要有记录,如果记录的信号触发过了就不在触发
zipWith 记录每一次信号 combineLatestWith记录最后一次的信号

merge

    // merge:把多个信号合并成一个信号
    //创建多个信号
    RACSignal *signalA = self.textField.rac_textSignal;
    RACSignal *signalB = [self.button rac_signalForControlEvents:UIControlEventTouchUpInside];
    RACSignal *mergeSignalA = [signalA merge:signalB];
    // 合并信号,任何一个信号发送数据，都能监听到
    [mergeSignalA subscribeNext:^(id  _Nullable x) {
        NSLog(@"mergeSignalA %@",x);//此处只打印一个信号而不是所所有的merge的信号都打印出来
    }];

then

    [[[RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        [subscriber sendNext:@"1"];
        [subscriber sendNext:@"2"];
        [subscriber sendCompleted];
        return nil;
    }] then:^RACSignal * _Nonnull{
        return [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
            [subscriber sendNext:@"3"];
            [subscriber sendCompleted];
            return nil;
        }];
    }] subscribeNext:^(id  _Nullable x) {
        NSLog(@"%@",x);
    }];

2019-01-31 17:37:47.485780+0800 RAC-OC_01[16000:626331] 3

concat

    RACSignal *signalA = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        
        [subscriber sendNext:@"1"];
        
        [subscriber sendCompleted];
        
        return nil;
    }];
    
    RACSignal *signalB = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        
        [subscriber sendNext:@"2"];
        
        [subscriber sendCompleted];
        
        return nil;
        
    }];
    
    RACSignal *contactSignal = [signalA concat:signalB];
    
    [contactSignal subscribeNext:^(id  _Nullable x) {
        
        NSLog(@"%@",x);
    }];

2019-01-31 17:38:27.049441+0800 RAC-OC_01[16021:627873] 1
2019-01-31 17:38:27.049640+0800 RAC-OC_01[16021:627873] 2

RACDisposable

    // 创建信号
    RACSignal *signal = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        // block调用时刻：每当有订阅者订阅信号，就会调用block。
        [subscriber sendNext:@"1"];
        [subscriber sendNext:@"2"];
        // 如果不在发送数据，最好发送信号完成，内部会自动调用[RACDisposable disposable]取消订阅信号。
//        [subscriber sendCompleted];
        
        NSLog(@"subscriber == %@",subscriber);
        [subscriber sendError:[NSError errorWithDomain:NSURLErrorDomain code:404 userInfo:nil]];
        RACDisposable *disposable = [RACDisposable disposableWithBlock:^{
            // 销毁信号
            // block调用时刻：当信号发送完成或者发送错误，就会自动执行这个block,取消订阅信号。
            // 执行完Block后，当前信号就不在被订阅了。
            NSLog(@"开始销毁");
        }];
        return disposable;
    }];
    
    //订阅信号,才会激活信号.
    [signal subscribeNext:^(id  _Nullable x) {
        NSLog(@"x == %@",x);
    }];
    [signal subscribeError:^(NSError * _Nullable error) {
        NSLog(@"error x == %@",error);
    }];

2019-01-31 17:39:33.777755+0800 RAC-OC_01[16053:630494] x == 1
2019-01-31 17:39:33.777906+0800 RAC-OC_01[16053:630494] x == 2
2019-01-31 17:39:33.778023+0800 RAC-OC_01[16053:630494] subscriber == <RACPassthroughSubscriber: 0x6000013d5240>
2019-01-31 17:39:33.778160+0800 RAC-OC_01[16053:630494] 开始销毁
2019-01-31 17:39:33.778382+0800 RAC-OC_01[16053:630494] subscriber == <RACPassthroughSubscriber: 0x600001387bc0>
2019-01-31 17:39:33.778538+0800 RAC-OC_01[16053:630494] error x == Error Domain=NSURLErrorDomain Code=404 "(null)"
2019-01-31 17:39:33.778648+0800 RAC-OC_01[16053:630494] 开始销毁

RACMulticastConnection

不加RACMulticastConnection

    RACSignal *signal = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        NSLog(@"网络请求 耗时操作,请求完成发送消息");
        [subscriber sendNext:@"wp"];
        return [RACDisposable disposableWithBlock:^{
            NSLog(@"disposable");
        }];
    }];
    [signal subscribeNext:^(id  _Nullable x) {
        NSLog(@"subscribeNext %@",x);
    }];
    [signal subscribeNext:^(id  _Nullable x) {
        NSLog(@"subscribeNext %@",x);
    }];

打印如下:

 2019-02-11 18:02:56.732035+0800 RAC-OC_01[11573:830470] 网络请求 耗时操作
 2019-02-11 18:02:58.688592+0800 RAC-OC_01[11573:830470] subscribeNext wp
 2019-02-11 18:02:58.688799+0800 RAC-OC_01[11573:830470] disposable
 2019-02-11 18:02:58.688936+0800 RAC-OC_01[11573:830470] 网络请求 耗时操作
 2019-02-11 18:03:00.462873+0800 RAC-OC_01[11573:830470] subscribeNext wp
 2019-02-11 18:03:00.463130+0800 RAC-OC_01[11573:830470] disposable

如果有两个订阅者,那么网络请求就会执行两次,这不是我们想看到了的,我们指向接收到两个请求数据而已,这回收就要用到RACMulticastConnection

    RACSignal *signal = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        NSLog(@"网络请求 耗时操作,请求完成发送消息");
        [subscriber sendNext:@"wp"];
        return [RACDisposable disposableWithBlock:^{
            NSLog(@"disposable");
        }];
    }];
    RACMulticastConnection *connection = [signal publish];
    [connection.signal subscribeNext:^(id  _Nullable x) {
        NSLog(@"subscribeNext %@",x);
    }];
    [connection.signal subscribeNext:^(id  _Nullable x) {
        NSLog(@"subscribeNext %@",x);
    }];
    [connection connect];

打印如下:

 2019-02-11 18:04:35.774205+0800 RAC-OC_01[11627:834289] 网络请求 耗时操作
 2019-02-11 18:04:35.774409+0800 RAC-OC_01[11627:834289] subscribeNext wp
 2019-02-11 18:04:35.774497+0800 RAC-OC_01[11627:834289] subscribeNext wp
 2019-02-11 18:04:35.781561+0800 RAC-OC_01[11627:834289] disposable

最后编辑于：2019.02.11 18:12:35

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

iOS RAC-进阶用法

map

filter 过滤

combine

takeUntil

retry

replay

timeOut

switchToLatest

take和takeLast

skip

distinctUntilChanged

ignore

reduce

zip

combineLatestWith

merge

then

concat

RACDisposable

RACMulticastConnection

推荐阅读更多精彩内容