ReactiveCocoa源码分析02 -- RACCommand

RACCommand
  • RACCommand:是对一个动作的触发条件以及它产生的触发事件的封装,最常见的使用场景为:点击按钮,发送一个网络请求;
    • 触发条件:初始化RACCommand的入参enabledSignal就决定了RACCommand是否能开始执行,入参enabledSignal就是触发条件,举个例子,一个按钮是否能点击,是否能触发点击事情,就由入参enabledSignal决定;
    • 触发事件:初始化RACCommand的另外一个入参(RACSignal * (^)(id input))signalBlock就是对触发事件的封装,RACCommand每次执行都会调用一次signalBlock闭包;
  • RACCommand内部存在四个信号属性,分别为:executionSignalsexecutingenablederrors,在RACCommand的构造函数initWithSignalBlock中会对以上四个信号进行初始化,下面对它们进行详细介绍;
  • executionSignals:是RACCommand 中最重要的信号,从类型上来看,它是一个包含信号的信号(高阶信号),在每次执行execute: 方法时,最终都会向 executionSignals 中传入一个最新的信号;
_executionSignals = [[[self.addedExecutionSignalsSubject
        map:^(RACSignal *signal) {
            return [signal catchTo:[RACSignal empty]];
        }]
        deliverOn:RACScheduler.mainThreadScheduler]
        setNameWithFormat:@"%@ -executionSignals", self];
  • 将信号中所有错误转换成RACEmptySignal空信号对象,并派发到主线程;
  • executing:表示RACCommand中是否有正在执行任务的信号;
_executing = [[[[[immediateExecuting
        deliverOn:RACScheduler.mainThreadScheduler]
        // This is useful before the first value arrives on the main thread.
        startWith:@NO]
        distinctUntilChanged]
        replayLast]
        setNameWithFormat:@"%@ -executing", self];
  • enabled:表示RACCommand命令是否可以再次被执行的信号,此信号依赖于另一个私有信号immediateEnabled
_immediateEnabled = [[[[RACSignal
        combineLatest:@[ enabledSignal, moreExecutionsAllowed ]]
        and]
        takeUntil:self.rac_willDeallocSignal]
        replayLast];
    
    _enabled = [[[[[self.immediateEnabled
        take:1]
        concat:[[self.immediateEnabled skip:1] deliverOn:RACScheduler.mainThreadScheduler]]
        distinctUntilChanged]
        replayLast]
        setNameWithFormat:@"%@ -enabled", self];
  • errors:是RACCommand中错误信号;
RACMulticastConnection *errorsConnection = [[[self.addedExecutionSignalsSubject
        flattenMap:^(RACSignal *signal) {
            return [[signal
                ignoreValues]
                catch:^(NSError *error) {
                    return [RACSignal return:error];
                }];
        }]
        deliverOn:RACScheduler.mainThreadScheduler]
        publish];
    
    _errors = [errorsConnection.signal setNameWithFormat:@"%@ -errors", self];
    [errorsConnection connect];
  • 从上一篇的内容我们知道信号的使用步骤为:创建信号,订阅信号,发送信号内容,订阅者接收到信号内容,核心部分为信号,此信号是一阶信号,若创建的信号为二阶信号,那么发送的信号内容就是一阶信号,此一阶信号也是能被订阅的,下面提供一段RACCommand使用的测试代码:
@implementation ViewController

- (void)viewDidLoad {
    [super viewDidLoad];
    
    RACCommand *command = [[RACCommand alloc]initWithSignalBlock:^RACSignal * _Nonnull(id  _Nullable input) {
        NSLog(@"执行1");
        //创建一个一阶信号 此信号会传递给RACCommand内部属性executionSignals
        RACSignal *signal = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
            NSLog(@"执行3");
            [subscriber sendNext:input];
            return nil;
        }];
        return signal;
    }];
    
    //一阶信号 -- 信号内容(具象数据)
    //二阶信号 -- 信号内容(一阶信号)
    //command.executionSignals是一个高阶信号
    //订阅command的executionSignals信号
    [command.executionSignals subscribeNext:^(id  _Nullable x) {
        //x是接收的信号内容 是一个一阶信号
        [x subscribeNext:^(id  _Nullable x) {
           NSLog(@"执行4");
           NSLog(@"接收数据 -- %@",x);
        }];
        NSLog(@"执行2");
    }];
    
    //订阅command的executing信号
    [command.executing subscribeNext:^(NSNumber * _Nullable x) {
        NSLog(@"executing == %@",x);
    }];

    //订阅command的error信号
    [command.errors subscribeNext:^(NSError * _Nullable x) {
        NSLog(@"errors == %@",x);
    }];

    [command execute:@"发送消息"];
}
@end
  • 测试结果如下:
image.png
  • 第一步:创建RACCommand命令,同时传入参数block代码块;
image.png
  • 构造方法中会对RACCommand的四种信号进行初始化;
  • 第二步:RACCommand命令执行execute方法,内部会调用保存的block代码块;
image.png
  • 整体的逻辑流程如下所示:
image.png
  • 其中二阶信号executionSignals的创建实在RACCommand的构造函数中;

推荐阅读更多精彩内容