美文网首页
RACsignal、RACSubject、RACReplaySu

RACsignal、RACSubject、RACReplaySu

作者: Qing学 | 来源:发表于2018-01-26 14:33 被阅读0次

通过RAC我们使用MVVM框架。可以较为优雅的解决MVC模型中Controller过于臃肿的问题。而且RAC提供了统一的消息转发机制。比较方便管理。
一、RACSignal的创建:

    RACSignal *defaultSignal = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
        NSLog(@"信号被执行");
        [subscriber sendNext:@"testABC"];
        [subscriber sendCompleted];
        return [RACDisposable disposableWithBlock:^{
            NSLog(@"%@",@"当前信号已经被销毁了");
        }];
    }];

RACSignal信号的订阅:

    QXWTestSignalObject *testObject = [[QXWTestSignalObject alloc]init];
    [[testObject getTestSignal]subscribeNext:^(id x) {
        NSString *str = (NSString *)x;
        NSLog(@"%@",str);
    }];

下面我们通过实例来分析下RACSignal信号的特点、
controller中信号的订阅情况为

QXWTestSignalObject *testObject = [[QXWTestSignalObject alloc]init];
    [[testObject getTestSignal]subscribeNext:^(id x) {
        NSString *str = (NSString *)x;
        NSLog(@"%@",str);
    }];
    [[testObject getTestSignal]subscribeNext:^(id x) {
        NSString *str = (NSString *)x;
        NSLog(@"第二次订阅信号执行结果为%@",str);
    }];

执行结果为:
2018-01-26 13:42:49.907605+0800 RacReplaySubjectTest[2249:105392] 信号被执行
2018-01-26 13:42:49.907978+0800 RacReplaySubjectTest[2249:105392] testABC
2018-01-26 13:42:49.908207+0800 RacReplaySubjectTest[2249:105392] 当前信号已经被销毁了
2018-01-26 13:42:49.908419+0800 RacReplaySubjectTest[2249:105392] 信号被执行
2018-01-26 13:42:49.908589+0800 RacReplaySubjectTest[2249:105392] 第二次订阅信号执行结果为testABC
2018-01-26 13:42:49.908710+0800 RacReplaySubjectTest[2249:105392] 当前信号已经被销毁了
我们对以上内容进行分析:可以看到“信号被执行”输出了两次
每次订阅信号的时候信号的创建内部的didSubscribe代码块都会执行一次。然后将订阅block的参数传递给订阅者。都次对于信号的订阅都会执行一次didSubscribe。只看看过一篇文章对RACSignal的底层做了一个讲解。如下
1.创建信号只是把信号的didSubscribe保存到信号中。并不会触发。
2.信号的订阅即使调用信号的subscribeNext方法
3.对信号进行订阅的时候会创建订阅者subscriber,并把nextBlock保存到subscriber中。
4.subscriberNext会自动调用subscriber信号的didSubscribe方法。
5.didSubScribe会调用subscriber的sendNext()方法
6.调用subscriber的sendNext()方法就是调用subscriber保存的nextBlock;
二、RACSubject的创建和使用
RACSubject订阅后才能接收到信号。订阅前的信号无法接收到。
创建:

RACSubject *subjectDefault = [RACSubject subject];

信号的订阅:

[subjectDefault subscribeNext:^(id x) {
        NSString *paramString = (NSString *)x;
        NSLog(@"信号发送前订阅%@",paramString);
    }];

下面还是通过代码实例讲解下racSubject的特性:

    RACSubject *subjectDefault = [RACSubject subject];
    [subjectDefault subscribeNext:^(id x) {
        NSString *paramString = (NSString *)x;
        NSLog(@"信号发送前订阅%@",paramString);
    }];
    [subjectDefault sendNext:@"subject信号发送"];
    [subjectDefault subscribeNext:^(id x) {
        NSString *paramString = (NSString *)x;
        NSLog(@"信号发送后订阅%@",paramString);
    }];

控制台输出为

2018-01-26 14:12:45.244354+0800 RacReplaySubjectTest[2371:119306] 信号发送前订阅subject信号发送

可以看到只有在信号订阅前发送的消息才能够正常接收
三、RACReplaySubject
RACReplaySubejct既可以接受到订阅前的信号,也可以接受到订阅后的信号。
证明代码如下:

    RACReplaySubject *replaySubject = [RACReplaySubject subject];
    [replaySubject subscribeNext:^(id x) {
        NSString *signalStr = (NSString *)x;
        NSLog(@"信号发送前订阅%@",signalStr);
    }];
    [replaySubject sendNext:@"replaySubject信号发送"];
    [replaySubject subscribeNext:^(id x) {
        NSString *signalStr = (NSString *)x;
        NSLog(@"信号发送后订阅%@",signalStr);
    }];

控制台输出为:

2018-01-26 14:19:15.920820+0800 RacReplaySubjectTest[2437:123082] 信号发送前订阅replaySubject信号发送
2018-01-26 14:19:15.921018+0800 RacReplaySubjectTest[2437:123082] 信号发送后订阅replaySubject信号发送

“信号发送前订阅replaySubject信号发送”完成了正常打印
分析可得信号订阅前发送的信号也被正常的订阅接收。

总结分析
RACSignal:每次订阅都会完整的执行didSubscriber方法。重新调用新的nextBlock()
RACSubject:只能接收到订阅后发送的消息。订阅前的信号无法正常接收
RACReplaySubject:调用sendNext()的时候会自动把值保存起来。同时每次订阅会把nextBlock保存起来。每次订阅会根据保存的值遍历调用保存的nextBlock。(此方法在ViewModel进行数据请求的使用中比较方便)

相关文章

网友评论

      本文标题:RACsignal、RACSubject、RACReplaySu

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