ReactiveCocoa源码分析02 -- RACComman

RACCommand

• RACCommand：是对一个动作的触发条件以及它产生的触发事件的封装，最常见的使用场景为：点击按钮，发送一个网络请求；
  • 触发条件：初始化RACCommand的入参enabledSignal就决定了RACCommand是否能开始执行，入参enabledSignal就是触发条件，举个例子，一个按钮是否能点击，是否能触发点击事情，就由入参enabledSignal决定；
  • 触发事件：初始化RACCommand的另外一个入参(RACSignal * (^)(id input))signalBlock就是对触发事件的封装，RACCommand每次执行都会调用一次signalBlock闭包；
• RACCommand内部存在四个信号属性，分别为：executionSignals，executing，enabled，errors，在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的构造函数中；