ReactiveCocoa 学习笔记（二）

正如上文中所说，ReactiveCocoa提供了一个标准接口来处理应用程序中发生的不同事件流。在ReactiveCocoa术语中，这些被称为信号，并由RACSignal类表示。
ReactiveCocoa信号（RACSignal）向其订阅者发送事件流。有三种类型的事件要知道：next，error和completed。一个信号可能发送任何数量的下一个事件，在它发生错误(error)或终止之后终止(completed)。
RACSignal有许多方法可以用来订阅不同的事件类型。每种方法都需要一个或多个block，当事件发生时，block中的逻辑会执行。在这种情况下，您可以看到该subscribeNext:方法用于提供在每个下一个事件上执行的block。
ReactiveCocoa框架使用类(category)对许多标准UIKit控件添加信号，以便将订阅添加到其事件中.

响应式编程的本质可以看做是一个信号管道(pipeline)，single在管道中流动，管道中有各个不同功能的功能，可以添加和删除这些功能（next,error,completed,filter,map等等）。响应式编程可以在数据流方面表达应用程序的功能。ReactiveCocoa有大量的操作符可以用来操作事件流.

#监听textField输入的字符串，用 filter: 判断 字符串的长度是不是大于3。
# fulter 返回yes 才会执行后面的subscribeNext：block中的代码。
[[self.textField.rac_textSignal
      filter:^BOOL(NSString* value) {
        return value.length >3;
    }]subscribeNext:^(id x) {
        NSLog(@"%@",x);
    }];

image

//创建textField输入信号
RACSignal * textSignal = self.textField.rac_textSignal;
//过滤信号    
RACSignal *filterSignal =  [textSignal filter:^BOOL(NSString* value) {
    return value.length >3;
}];
//输出    
[filterSignal subscribeNext:^(id x) {
        NSLog(@"%@", x);
    }];

每一个RACSignal操作返回的都是一个RACSignal对象，叫做连贯接口。

举个🌰，添加一个数据转换的功能：

image.png

新添加的map事件提供block数据转换，返回了NSNumber类型。所以不管是filter：还是subscribeNext：所接受的值的class都已成NSNumber了。

image

tip: RACSignal中的的每个事件如果有返回值，则都是都必须是对象。而text.length是基本类型.所以需要转换成对象。

创建信号

用代码解释：

//创建一些信号，判断用户名和密码是否有效（暂且用length >3 判断是否有效）
//返回的是 BOOL 不是对象，转换成 NSNumber
RACSignal * validUsernameSignal =[self.usernameTextField.rac_textSignal
    map：^ id（NSString * text）{
       return @（text.length > 3）;
}];
RACSignal * validPasswordSignal =[self.passwordTextField.rac_textSignal
    map：^ id（NSString * text）{
       return @（text.length > 3）;
}];

//转换信号，改变 TextField 背景色
[validUsernameSignal map：^ id（NSNumber * passwordValid）{
     return [passwordValid boolValue]？[ UIColor clearColor]：[ UIColor yellowColor];
  }]subscribeNext：^（UIColor * color）{
     self .usernameTextField.backgroundColor = color;
  }];
[validPasswordSignal map：^ id（NSNumber * passwordValid）{
     return [passwordValid boolValue]？[ UIColor clearColor]：[ UIColor yellowColor];
  }]subscribeNext：^（UIColor * color）{
     self .passwordTextField.backgroundColor = color;
  }];
  

ReactiveCocoa有一个宏，可以让你用优雅表示

//根据验证结果改变输入框颜色
RAC（self.passwordTextField，backgroundColor）=[validPasswordSignal
    map：^ id（NSNumber * passwordValid）{
       return [passwordValid boolValue]？[ UIColor clearColor]：[ UIColor yellowColor];
    }];
RAC（self.usernameTextField，backgroundColor）=[validUsernameSignal
    map：^ id（NSNumber * passwordValid）{
      return [passwordValid boolValue]？[ UIColor clearColor]：[ UIColor yellowColor];
    }];

image
RAC()：将信号的输出分配到一个对象的属性。它有两个参数，第一个是包含要设置的属性的对象，第二个是属性名称，每次信号发出下一个事件时，通过的值被分配给给定的属性。

组合信号

上面的代码已经有发出布尔值的信号，以指示用户名和密码字段是否有效; validUsernameSignal和validPasswordSignal。结合这两个信号来确定何时可以启用按钮。

RACSignal * signUpActiveSignal = 
[RACSignal combineLatest:@[validUsernameSignal,validPasswordSignal]
            reduce:^ id(NSNumber * usernameValid,NSNumber * passwordValid){
    return @([usernameValid boolValue] && [passwordValid boolValue]);
}];
//按钮是否可以点击    
[signUpActiveSignal subscribeNext：^（NSNumber * signupActive）{
    self .signInButton.enabled = [signupActive boolValue];
 }]; 

combineLatest:reduce: 是用来合并validUsernameSignal和validUsernameSignal的信号，得到一个新的信号。不管两个源信号中的任何一个发出新值，reduce:block就会执行，并返回的值将作为组合信号的下一个值发送。

image

• 分裂 - 信号可以有多个订阅者，并作为更多的后续步骤的来源。在上图中，请注意指示密码和用户名有效性的布尔信号被拆分并用于几个不同的目的。
• 组合 - 可以组合多个信号来创建新的信号。在这种情况下，两个布尔信号被组合。但是，您可以组合发出任何值类型的信号。

TIP:

• combineLatest:reduce: 该RACSignal组合方法可以结合任何数目的信号，并且减少block的参数对应于每个源极信号.
• ReactiveCocoa有一个小巧的小工具类，RACBlockTrampoline在内部处理reduce块的可变参数列表。实际上，在ReactiveCocoa实现中隐藏了很多小巧的技巧，所以很值得看看！

在用户名和密码有效时启用该按钮.

//对登录按钮添加一个信号，并订阅，监听按钮点击ControlEvents
[[self.signInButton
      rac_signalForControlEvents:UIControlEventTouchUpInside]
     subscribeNext:^(id x) {
         NSLog(@"SignInButton clicked");
}];

将异步操作为改信号返回
在登录按钮中添加登录请求的异步操作。[self.signInService signInWithUsername:password: complete:这是模拟的网路请求回调。这时返回的就是一个RACSignal。

-(RACSignal *)signInSignal {
/*
* createSignal： 创建信号。
*/
    return [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
        [self.signInService signInWithUsername:self.usernameTextField.text
         password:self.passwordTextField.text
         complete:^(BOOL success) {
            //返回结果
             [subscriber sendNext:@(success)];
             [subscriber sendCompleted];
         }];
        return nil;
    }];
}

描述此信号的block参数是一个RACSubscriber，当这个信号有一个用户时，这个block内的代码执行,传递的subscriber是RACSubscriber协议的实例，需要返回异步结果到下一步，next之后，需要Completed或Error。这样这个信号才算传输完成。
返回值返回的是RACDisposable，允许对其进行清理操作。但是我们只需要信号传递出结果。所以不需要返回值，所以返回nil。

结合上面的代码，修改登录操作为：

[[[self.signInButton
       rac_signalForControlEvents:UIControlEventTouchUpInside]
      map:^id(id x) {
          return [self signInSignal];
      }]
     subscribeNext:^(id x) {
         NSLog（@“登录结果：％@”，x）;
     }];

我们需要判断登录结果，这里不能使用map，这样会使subscribeNext接受next信号的是map:的映射值而不是异步登录的结果，当打印signedIn的时候会再控制台看到这样的东西：<RACDynamicSignal：0xa068a00> name：+ createSignal：。

当rac_signalForControlEvents 发出next的操作（和源UIButton作为其事件数据）时点击按钮。map返回的是映射值也就是BUtton的single，而不是[self signInSignal]next的success。

image
这种情况被称为信号的信号，就是外部信号的内部信号。[self signInSignal]返回的信号是内部信号，rac_signalForControlEvents返回的是外部部信号，这样就会返回的是button的rac_signalForControlEvents信号而不是 [self signInSignal]。

而为了解决这个问题，只需要把map修改为flattenMap,过滤掉了rac_signalForControlEvents的signal，。然后在subscribeNext:的block中添加上逻辑判断就可以完成登录了。

[[[self.signInButton
   rac_signalForControlEvents:UIControlEventTouchUpInside]
  flattenMap:^id(id x) {
      return [self signInSignal];
  }]
 subscribeNext:^(NSNumber *signedIn) {
     BOOL success = [signedIn boolValue];
     self.signInFailureText.hidden = success;
     if (success) {
         NSLog(@"登录成功 %@ ",signedIn);
     }
 }];

添加附加操作
在开发中，我们会使用转圈的指示器来模仿阻塞模式防止用户重复发起网络请求。但是需求是点击后立刻使self.signInButton的 enabled 设置为 NO。而且需要隐藏提示语的signInFailureLabel。
这个时候就需要使用附加操作doNext:，在一个next事件发生时执行的逻辑，而该逻辑并不改变事件本身。

[[[[self.signInButton
        rac_signalForControlEvents:UIControlEventTouchUpInside]
       doNext:^(id x) {
           self.signInButton.enabled = NO;
           self.signInFailureText.hidden = YES;
    }]flattenMap:^RACStream *(id value) {
        return [self signInSignal];
    }]subscribeNext:^(id x) {
        BOOL success = [signedIn boolValue];
     self.signInFailureText.hidden = success;
     if (success) {
         NSLog(@"登录成功 %@ ",signedIn);
     }
}];

doNext：是直接更在按钮点击事件的后面，并且doNext:没有返回值，因为是附加操作，所以不改变事件的本身逻辑。

image

Tip:在异步加载中禁用按钮是比较常见的，使用RACCommand中的enabled可以很好的解决这种问题。

ReactiveCocoa的核心是信号，它不过是事件流.利用ReactiveCocoa对信号管道的拆分组合会有很多方法解决一个问题。ReactiveCocoa的主要目标是让你的代码更清晰，更易于理解.

DEMO

参考：ReactiveCocoa Tutorial – The Definitive Introduction: Part 1/2