ReactiveCocoa2
RACCommand
理解：个人觉得是对RACSignal的封装，侧重于对事件的信号的封装。有了RACComand，就可以把动作通过它很方便的放到ViewModel中，类似于以下这种方式:
1.在ViewModel中定义RACCommand
@interface SubscribeViewModel : NSObject
@property(nonatomic, strong) RACCommand *subscribeCommand;
@end
2.在ViewModel中处理具体的RACCommand封装的动作信号
- (RACCommand *)subscribeCommand {
if (!_subscribeCommand) {
NSString *email = self.email;
_subscribeCommand = [[RACCommand alloc] initWithEnabled:self.
emailValidSignal signalBlock:^RACSignal *(id input) {
return [SubscribeViewModel postEmail:email];
}];
}
return _subscribeCommand;
}
input参数是在command调用excute方法的时候传进来的。
3.在ViewController中将ViewModel的RACCommand绑定到控件的事件信号上
self.subscribeButton.rac_command = self.viewModel.subscribeCommand;
如果要对某个行为进行单元测试也非常方便，直接对ViewModel层进行测试就可以了，并且没有任务Uiew层的显示逻辑，纯业务逻辑测起来很方便。如果没有RACCommand，直接通过signal去处理，可能类似这种方式：
[[self.button rac_signalForControlEvents:UIControlEventTouchUpInside]
subscribeNext:^(id x) {
}];
直接在ViewController中定义了动作的逻辑，没有很好的分离。
初始化
_subscribeCommand = [[RACCommand alloc] initWithEnabled:self.emailValidSignal
signalBlock:^RACSignal *(id input) {
return [SubscribeViewModel postEmail:email];
}];
signalBlock必须要返回一个信号，不能传nil，如果不想传递信号，则可以创建空的信号
[RACSignal empty]
RAC
emailValidSignal用来指定创建的命令是否能够执行，self.emailValidSignal定义如下:
_emailValidSignal = [RACObserve(self, email) map:^id(NSString *email) {
return @([email isValidEmail]);
}];
当self.emailValidSignal信号返回数据为yes的时候，_subscribeCommand才能够响应行为
signalBlock是当_subscribeCommand执行的时候会被调用的逻辑，该block返回的是一个包含了命令执行之后结果的signal。
属性
allowsConcurrentExecution代表当该命令正在执行的时候，是否能够再次触发改命令。
RACCommand内部是如何通过它去控制当前命令能不能够被执行以及能不能并发的执行:
以UIButton举例：
UIButton+RACCommandSupport.m
//UIButton的enabel和command的enabel绑定起来了，也就是如果command的enabel
//设置未false，那么button则不可用。
disposable = [command.enabled setKeyPath:@keypath(self.enabled) onObject:self];
以下是RACCommand中有关allowsConcurrentExecution的源码:
if (enabledSignal == nil) {
enabledSignal = [RACSignal return:@YES];
} else {
enabledSignal = [[[enabledSignal
startWith:@YES]
takeUntil:self.rac_willDeallocSignal]
replayLast];
}
_immediateEnabled = [[RACSignal
combineLatest:@[ enabledSignal, moreExecutionsAllowed ]]
and];
_enabled = [[[[[self.immediateEnabled
take:1]
concat:[[self.immediateEnabled skip:1] deliverOn:RACScheduler.
mainThreadScheduler]]
distinctUntilChanged]
replayLast]
setNameWithFormat:@"%@ -enabled", self];
整个command是否可用，是由immeditateEnable来决定的，而imediateEnabled是取enableSignal和moreExecutionsAllowed的与操作。
enableSignal是command初始化方法传进来的第一个参数。
RACSignal *immediateExecuting = [RACObserve(self, activeExecutionSignals) map:^
(NSArray *activeSignals) {
return @(activeSignals.count > 0);
}];
RACSignal *moreExecutionsAllowed = [RACSignal
if:RACObserve(self, allowsConcurrentExecution)
then:[RACSignal return:@YES]
else:[immediateExecuting not]];
imediateExecuting是当前正在执行未完成的命令数量的信号，如果command的allowsConcurrentExecution设置的yes，则moreExcutionsAllowed返回yes，反之则取决于有没有正在执行的信号，如果有就返回false，没有返回yes。一个信号是否执行完，根据signal有没有发出complete事件来判断的。
方法
excute
RACSignal *signal =[command execute:@2];
在command的初始化方法中，有一个signalBlock参数，该block有一个input参数，在command执行excute方法的时候传入的参数被当作signalBlock的input参数传到signalBlock中。比如通常将一个网络请求的封装成一个Command，此时网络请求的参数就可以通过调用excute的时候传入。
这种情况下，获取command执行之后返回的数据可以通过:
RACSignal *signal =[command execute:@2];
// 在这里就可以订阅信号了
[signal subscribeNext:^(id x) {
NSLog(@"%@",x);
}];
订阅命令完成的信号
[[self.viewModel.subscribeCommand execute:nil] subscribeCompleted:^{
NSLog(@"The command executed");
}];
executionSignals
属于信号中的信号，在subscribeNext中返回的是信号x，再次订阅信号x才能获取具体数据
[command.executionSignals subscribeNext:^(RACSignal *x) {
[x subscribeNext:^(id x) {
NSLog(@"%@", x);
}];
也可以直接使用excutionSignals.switchToLatest subscribeNext:获取到数据
// 监听登录产生的数据
[_LoginCommand.executionSignals.switchToLatest subscribeNext:^(id x) {
if ([x isEqualToString:@"登录成功"]) {
NSLog(@"登录成功");
}
}];
