美文网首页IOS知识积累MVVM_RACiOS面试题
iOS RAC - RACSubject、RACReplaySu

iOS RAC - RACSubject、RACReplaySu

作者: Codepgq | 来源:发表于2017-07-16 16:36 被阅读630次

    文章系列
    《RACSignal 》
    《RACDisposable》
    《RACSubject、RACReplaySubject》
    《iOS RAC - 基本用法》
    《iOS RAC - 定时器》
    《iOS RAC - RACMulticastConnection》
    《iOS RAC - RACCommand》
    《iOS RAC - 核心方法bind》
    《iOS RAC - 集合RACTuple、RACSequence》
    《iOS RAC - rac_leftSelector》
    《iOS RAC - 映射》
    《iOS RAC - 过滤》
    《iOS RAC - 登录页面,MVVM》

    之前有提到过RACSignal是不具备发送信号的能力的,但是RACSubject这个类就可以做到订阅/发送为一体。
    之前还提到过RAC三部曲,在RACSuject中同样适用。

    <br / >

    然后我们先创建一个简单的代码段,然后接着分析分析。
        //1创建信号,
        RACSubject * subject = [RACSubject subject];
        
        //2订阅信号 
        [subject subscribeNext:^(id  _Nullable x) {
            NSLog(@"%@",x);
        }];
       
        //3发送数据
        [subject sendNext:@"发送数据"];
    

    <br />

    • 1. 先看看创建信号会干啥吧
    sbuject

    从上图中可以很直观的看到 调用subject方法内部事创建了一个_disposable取消信号和一个数组_subscribers,这个数组从命名上就可以看出来这个数组事,用来保存订阅者。

    <br />

    • 2. 然后是订阅信号
    - (RACDisposable *)subscribeNext:(void (^)(id x))nextBlock {
        NSCParameterAssert(nextBlock != NULL);
        
        RACSubscriber *o = [RACSubscriber subscriberWithNext:nextBlock error:NULL completed:NULL];
        return [self subscribe:o];
    }
    

    这里很简单,创建一个订阅者,然后调用 self subscribe:o]方法,细心的你可能还记得在RACSignal中也调用了这个方法,但是需要注意的是这两个方法并不是一个方法,内部实现不一样。

    选中这个方法进去


    如何进去

    内部实现代码:


    内部实现

    通过上面的代码截图我们得知了,在订阅的时候会把订阅者会把订阅者保存到一开创建RACSubject中的数组_subscribers中去。

    <br />

    • 3. 最后是发布信息
    [subject sendNext:@"发送数据"];
    

    点进去继续看看内部实现吧

    发布信息

    <br />

    • 总结:

    1、创建的subject的是内部会创建一个数组_subscribers用来保存所有的订阅者
    2、订阅信息的时候会创建订阅者,并且保存到数组中
    3、遍历subject中_subscribers中的订阅者,依次发送信息

    • 所以对于RACSignal不同的地方是:他可以被订阅多次,并且只能是先订阅后发布。

    验证验证:

    Paste_Image.png

    <br />
    从上面的代码中可以明确的看到,第一次发送的字符串是没有收到的,所以证明了RACSubject只能订阅之后,发送数据才收到
    然后我们订阅多次信号,然后发送数据,我们可以看到收到了两次数据。
    💯所以可以得到上面的总结是没有错误的。

    <br />

    最后还有一个小问题,那就是如果我非要先发送在订阅,并且也要能收到怎么处理呢?

    当然是有办法的啦,主角来了,自带(赌神)声音。。。。

    RACReplaySubject,他继承RACSubject,他的目的就是为例解决上面必须先订阅后发送的问题。

    运行截图

    一样的三行代码,运行出来的结果遇上面的不一致,难道不想看看嘛?哈哈,我反正是有兴趣了,ok,来分析吧。

    <br />

    • 1 创建信号

    还记得RACSubject就是在init中做了初始化,不记得就到文章开头开开,所以我们直接看他对init做了啥处理吧

    init

    <br />

    • 2 发送信号

    - (void)sendNext:(id)value {
        @synchronized (self) {
            [self.valuesReceived addObject:value ?: RACTupleNil.tupleNil];
            [super sendNext:value];
            
            if (self.capacity != RACReplaySubjectUnlimitedCapacity && self.valuesReceived.count > self.capacity) {
                [self.valuesReceived removeObjectsInRange:NSMakeRange(0, self.valuesReceived.count - self.capacity)];
            }
        }
    }
    

    可以看到代码中在发送之前做了一件事情,把要发送的数据保存到数组中,然后调用父类的发送方法,发送玩了看发送成功了没,成功了就删除数据,避免一个数据多次发送。

    • 3 订阅信号

    订阅信号

    总结:

    1、创建的时候会在父类的基础之上多做一步,创建一个数组用来保存发送的数据
    2、发送数据,但是此时发送会失败啊,为什么?因为没有人订阅啊,我发给谁啊。
    3、订阅信号,先遍历一次保存数据的数组,如果有就执行 2 。

    相关文章

      网友评论

      • Simon_____:“可以看到代码中在发送之前做了一件事情,把要发送的数据保存到数组中,然后调用父类的发送方法,发送玩了看发送成功了没,成功了就删除数据,避免一个数据多次发送。”
        大佬,RACReplaySubject怎么知道发送成功了没有啊??
        小鬼快跑:@闫仕伟 确实如你所说. 灰常感谢
        闫仕伟:这里应该理解有误,self.capacity应该是表示最大可存储的信号数量,如果超过这个限制,从第0个开始,删除多余的条数的信号。发送的信号应该是一直保存在repalyObject里面的,可以通过代码试一下,多次订阅之后,每一次都能收到前面发送的信号,并不存在上面说的发送完后就删除的情况。

      本文标题:iOS RAC - RACSubject、RACReplaySu

      本文链接:https://www.haomeiwen.com/subject/zuzahxtx.html