ReactiveCocoa基本组件：深入浅出RACCommand

原文地址在这里。

本文源码：https://github.com/olegam/RACCommandExample

RACCommand

RACCommand是ReactiveCocoa的基本组件之一，能节省开发的大部分时间，同时使得iOS/OS X 应用更健壮。

我看到一部分ReactiveCocoa（以下简单RAC）新人并没有完全理解RACCommand，自然也就不知道怎么用它。所以我写了这个小小介绍性文章，希望能对你的理解有所帮助。RACCommand源文件里的注释写得很不错，不过它并没有给任何例子来说说具体怎么用它，对于RAC的新人来说，只看这些注释还是比较难以理解的。

RACCommand类用于表示事件的执行，一般来说是在UI上的某些动作来触发这些事件，比如点击一个按钮。RACCommand的实例能够决定是否可以被执行，这个特性能反应在UI上，而且它能确保在其不可用时不会被执行。通常，当一个命令可以执行时，会将它的属性allowsConcurrentExecution设置为它的默认值：NO，从而确保在这个命令已经正在执行的时候，不会同时再执行新的操作。命令执行的返回值是一个RACSignal，因此我们能对该返回值进行next:，completed或error:，这在下文会有所展示。

例子应用

现在假设我们要写一个简单的iOS APP，它能让用户订阅邮件列表。我们将其做到最简单：一个输入框和一个按钮。当用户输入了电子邮箱地址、点击订阅按钮后，电子邮箱地址会提交到我们的web服务器上。够简单了吧！然而，我们还是得处理一些边界情况，以提供最好的体验。比如如果用户点击按钮两次怎么办？错误如何处理？如果邮箱地址非法呢？RACCommand能帮助我们处理这些情况。我已经实现了一个小的app来演示本文中所讨论的这些概念。

源码：https://github.com/olegam/RACCommandExample

本例用了一个非常简单的视图控制器，同样还演示了iOS应用的MVVM模式。

根视图控制器包含了视图，还有view model的实例。

@H_502_24@- (void)bindWithviewmodel { RAC@H_502_26@(self@H_502_26@.viewmodel,email) =self@H_502_26@.emailTextField.rac_textSignal; self@H_502_26@.subscribeButton.rac_command = self@H_502_26@.viewmodel.subscribeCommand; RAC@H_502_26@(self@H_502_26@.statusLabel,text) =RACObserve@H_502_26@(self@H_502_26@.viewmodel,statusMessage); }

上面的这个方法（在viewDidLoad中调用）将view以及view model绑定。对于咱们感兴趣的代码在都view model中。看看view model的接口：

@interface@H_502_26@ Subscribeviewmodel :NSObject  
  @property@H_502_26@(nonatomic,strong)RACCommand *subscribeCommand@H_502_26@;  //@H_502_26@ writeto this property
  *email@H_502_26@;  //@H_502_26@ read@H_502_26@ from this property
  *statusMessage@H_502_26@;  
@end@H_502_26@

RACCommand暴露在这里，就是本文接下来要讨论的。另外还有两个被绑定到view上用于展示的字符串。这个view model的完整实现如下：

#import "Subscribeviewmodel.h"@H_502_26@
#import "AFHTTPRequestOperationManager+RACSupport.h"@H_502_26@
#import"NSString+EmailAdditions.h"@H_502_26@
 
static NSString *const@H_502_26@ kSubscribeURL =@"@H_502_26@http://reactivetest@H_502_26@.apiary.io/subscribers";
 
@interface@H_502_26@ Subscribeviewmodel ()
*emailValidSignal@H_502_26@;
@end@H_502_26@
 
@implementation@H_502_26@ Subscribeviewmodel
 
- (id)init {
 @H_502_26@self= [super init];
 @H_502_26@if(self) {
 @H_502_26@ @H_502_26@[selfmapSubscribeCommandStateToStatusMessage];
 @H_502_26@}
 @H_502_26@returnself;
}
 
-(void)mapSubscribeCommandStateToStatusMessage {
 @H_502_26@RACSignal*startedMessageSource@H_502_26@ = [self.subscribeCommand.executionSignalsmap:^id(RACSignal *subscribeSignal@H_502_26@) {
 @H_502_26@ @H_502_26@returnNSLocalizedString(@"@H_502_26@Sending request..."@H_502_26@,nil);
  @H_502_26@}];
 
  @H_502_26@RACSignal*completedMessageSource@H_502_26@ = [self.subscribeCommand.executionSignalsflattenMap:^RACStream *(@H_502_26@RACSignal *subscribeSignal@H_502_26@) {
  @H_502_26@  @H_502_26@return@H_502_26@[[[subscribeSignal materialize] filter:^BOOL(RACEvent *event@H_502_26@) {
  @H_502_26@  @H_502_26@  @H_502_26@returnevent.eventType == RACEventTypeCompleted;
  @H_502_26@  @H_502_26@}]map@H_502_26@:^id(id value) {
  @H_502_26@  @H_502_26@  @H_502_26@returnNSLocalizedString(@"@H_502_26@Thanks",nil);
 @H_502_26@ @H_502_26@}];
 @H_502_26@}];
 
 @H_502_26@RACSignal*FailedMessageSource@H_502_26@ = [[self.subscribeCommand.errors subscribeOn:[RACSchedulermainThreadScheduler]] map:^id(NSError *error@H_502_26@) {
 @H_502_26@ @H_502_26@returnNSLocalizedString(@"@H_502_26@Error :("@H_502_26@,nil);
  @H_502_26@}];
 
  @H_502_26@RAC(self,statusMessage) = [RACSignal merge:@[@H_502_26@startedMessageSource,completedMessageSource,FailedMessageSource]];
}
 
- (RACCommand *)@H_502_26@subscribeCommand {
  @H_502_26@if@H_502_26@(!_subscribeCommand) {
  @H_502_26@  @H_502_26@@weakify@H_502_26@(self);
  @H_502_26@  @H_502_26@_subscribeCommand= [[RACCommand alloc] initWithEnabled:self.emailValidSignalsignalBlock:^RACSignal *(@H_502_26@id input) {
  @H_502_26@  @H_502_26@  @H_502_26@@strongify@H_502_26@(self);
  @H_502_26@  @H_502_26@  @H_502_26@return@H_502_26@[Subscribeviewmodel postEmail:self.email];
  @H_502_26@  @H_502_26@}];
  @H_502_26@}
  @H_502_26@return_subscribeCommand;
}
 
+ (RACSignal *)@H_502_26@postEmail:(NSString *)@H_502_26@email{
  @H_502_26@AFHTTPRequestOperationManager*manager@H_502_26@ = [AFHTTPRequestOperationManager manager];
  @H_502_26@manager.requestSerializer= [AFJSONRequestSerializer new];
  @H_502_26@NSDictionary*body@H_502_26@ = @{@"@H_502_26@email": email ?: @"@H_502_26@"@H_502_26@};
  @H_502_26@return@H_502_26@[[[manager rac_POST:kSubscribeURL parameters:body] logError] replayLazily];
}
 
- (RACSignal *)@H_502_26@emailValidSignal {
  @H_502_26@if@H_502_26@(!_emailValidSignal) {
  @H_502_26@  @H_502_26@_emailValidSignal= [RACObserve(self,email) map@H_502_26@:^id(NSString *email@H_502_26@) {
  @H_502_26@  @H_502_26@  @H_502_26@return@H_502_26@@(@H_502_26@[email isValidEmail]);
  @H_502_26@  @H_502_26@}];
  @H_502_26@}
  @H_502_26@return_emailValidSignal;
}
 
@end@H_502_26@
呃，这是个大块头，我们一点一点来看。我们最感兴趣的RACCommand的创建如下：
- (RACCommand @strongify@H_502_26@(self);
  @H_502_26@  @H_502_26@  @H_502_26@return@H_502_26@[Subscribeviewmodel postEmail:self.email];
  @H_502_26@  @H_502_26@}];
  @H_502_26@}
  @H_502_26@return_subscribeCommand;
}

command的初始化方法中有一个enabledSignal参数，这个signal就是用来指名command能否被执行的。在我们的例子中，当用户输入的email地址合法时，它才能被执行。self.emailValidSignal这个signal每当email的文本更新时，会发送NO或YES。

signalBlock参数在command需要执行时调用，这个block需要返回一个signal用来表示正在执行，之前将allowsConcurrentExecute的值设置为默认值NO，此时command会观察这个signal，而且在这个执行进度完成前，不允许新的执行。

由于command是button的rac_command的属性（定义在UIButton+RACCommandSupport），这个button的enable状态会根据command能否执行来自动改变。

当用户点击按钮时，command会自动执行。如果你需要手动执行command，可以发送消息：-[RACCommand execute:]，参数是可选的，在我们的例子中，我们不需要手动执行。尽管在我们这里不用，但它还是很有用的，这个-execute:方法是一个查看命令执行的状态的方法，如下：

[[self@H_502_26@.viewmodel.subscribeCommand execute:@H_502_26@nil@H_502_26@] subscribeCompleted:@H_502_26@^{
  NSLog@H_502_26@(@"Thecommand executed"@H_502_26@); 
}];

在我们的例子中，button自动执行command（所以我们不需要调用-execute:），所以我们得监听command的另一个属性，在command执行时更新UI。在这里有几种选择来达到目的，也许会有点小迷惑。executionSignals是RACCommand的signal，每当command开始执行时next:，其参数是由command创建的signal，所以这个executionSignals是一个值为signal的signal。我们在view model的mapSubscribeCommandStateToStatusMessage方法中，在command每次开始执行时得到一个包含字符串值的signal：

RACSignal*subscribeSignal@H_502_26@) {
  returnNSLocalizedString(@"@H_502_26@Sending request...502_26@

如果我们想用纯粹的函数在command执行完成后得到一个包含字符串的signal，我们不得不多做一点小工作：

RACSignal *completedMessageSource@H_502_26@ =[self.subscribeCommand.executionSignals flattenMap:^RACStream *(@H_502_26@RACSignal*subscribeSignal@H_502_26@) {
              return@H_502_26@[[[subscribeSignal materialize] filter:^BOOL(RACEvent *event@H_502_26@) {
                     returnevent.eventType == RACEventTypeCompleted;
              }]map@H_502_26@:^id(id value) {
                     returnNSLocalizedString(502_26@

flattenMap:方法在command执行时，会调用block并传入subscribeSignal，这个block会返回一个新的signal，它的值就在这个要返回的signal中。materialize会将一个signal转换为RACEvent信号（将一个signal的next:complete和error:消息转换为RACEvent实例的next:的值）。接下来我们就过滤这些事件，只留下RACEventTypeCompleted完成事件，并将其map成一个字符串值。看懂了没？如果没看懂的话，你最好看一下flattenMap:和materialize:是用来做什么的。

我们可以用一个不同的方法来实现上面这种行为，还可能更容易懂：

@weakify@H_502_26@(self@H_502_26@);
[self@H_502_26@.subscribeCommand.executionSignals subscribeNext:@H_502_26@^(RACSignal@H_502_26@*subscribeSignal) {  
   [subscribeSignalsubscribeCompleted:@H_502_26@^{      
    @strongify@H_502_26@(self@H_502_26@);     
    self@H_502_26@.statusMessage= @"Thanks"@H_502_26@;  
   }]; 
}];

我不推荐上面这种方法，因为在block里的是副作用（side effects）。还有，上面的block会referring和retaining self，所以我用了@weakify和@strongify宏（在libextobjc中定义）来避免循环引用。所以为了避免使用这种副作用，还是要尽量采用原始的实现好一些。

还有一个要重点注意的是executionSignals属性，这个signals不会发送了error事件，而是由errors这个属性来发送的。在一个command的执行期间，如果一个signal发送了error，这会被signals当成一个next:事件发送，而errors属性则会发送这个错误信息。errors属性不会发送error:事件。我们很容易就能将错误信息map成一个字符串消息：

*FailedMessageSource@H_502_26@ = [[self.subscribeCommand.erroRSSubscribeOn:[RACScheduler mainThreadScheduler]] map@H_502_26@:^id(NSError *error@H_502_26@) {
  returnNSLocalizedString(@"@H_502_26@Error :( 现在我们有3个关于状态的signals了，现在要展示给用户看，我们将这个3个signals合并成一个signal，并将其绑定到view model的statusMessage属性上（这会被绑定到view controller的statusLabel.text属性上）。 
RAC@H_502_26@(self@H_502_26@,statusMessage) = [RACSignalmerge@H_502_26@:@H_502_26@@[startedMessageSource,FailedMessageSource]]; 
 以上就是在iOS应用里怎么使用RACCommand的一例子了。我认为这个实现逻辑相比较于在view controller里用UITextFieldDegate实现来说要好得多，因为它不需要各种状态变量和属性。
 原文链接：https://www.f2er.com/react/307772.html

ReactiveCocoa基本组件：深入浅出RACCommand

猜你在找的React相关文章