ReactiveCocoa初探

什么是ReactiveCocoa

ReactiveCocoa为事件定义了一个标准接口，从而可以使用一些基本工具来更容易的连接、过滤和组合。
例如按钮的点击，收到网络消息，属性的变化（通过KVO）或者用户位置的变化（通过CoreLocation）。但是这些事件都用不同的方式来处理，比如action、delegate、KVO、callback等。ReactiveCocoa做了大一统。

ReactiveCocoa实现原理

首先RAC给每个控件都绑定了各种“signal感应器”，然后通过加工处理探测出的signal，或变成其他形式的信号，形成信号流，最后，将信号流的末端信号给订阅的block处理。通过这种方式实现了数据处理的大一统。

目前总共有三种类型的事件：next、error、completed。

1. 信号：

RACSignal使用步骤：

1. 创建信号 + (RACSignal *)createSignal:(RACDisposable * (^)(id<RACSubscriber> subscriber))didSubscribe
   这个block是定义了，订阅者和信号之间的关系。即何种情况下，信号发送next，complete还是Error信号给订阅者。
   其中block的返回值RACDisposable，是当信号发送完成或者发送错误,RACDisposable就会取消订阅信号。所以一般情况下，return nil就可以了。
2. 订阅信号,才会激活信号. - (RACDisposable *)subscribeNext:(void (^)(id x))nextBlock
3. 发送信号 - (void)sendNext:(id)value

2. 信号实例应用

信号的订阅

[[self.usernameTextField.rac_textSignal
filter:^BOOL(id value){
   NSString*text = value;
   return text.length > 3;
}]
subscribeNext:^(id x){
   NSLog(@"%@", x);
  }];

• 首先通过textField上面的textSignal获取文本框的文本信息，string类型
• 然后，string类型的文本信息，经过filter这个方法处理，只能让文本长度大于3的信号通过。
• 最后，通过的信号执行订阅的block

Paste_Image.png

ReactiveCocoa自己持有全局的所有信号。如果一个signal有一个或多个订阅者，那这个signal就是活跃的。如果所有的订阅者都被移除了，那这个信号就能被销毁了。

RACDisposable *subscription = 
    [backgroundColorSignal 
        subscribeNext:^(UIColor *color) {
            self.searchText.backgroundColor = color; 
    }]; 
    
// at some point in the future ... 
[subscription dispose];​

如上面所示，信号订阅了一个block，返回值为RACDisposable，表示这个订阅可以被移除。

[[[[self requestAccessToTwitterSignal] 
    then:^RACSignal *{ 
        @strongify(self) 
        return self.searchText.rac_textSignal; 
    }] 
    filter:^BOOL(NSString *text) { 
        @strongify(self) 
        return [self isValidSearchText:text]; 
    }] 
    subscribeNext:^(id x) { 
        NSLog(@"%@", x); 
    } error:^(NSError *error) { 
        NSLog(@"An error occurred: %@", error); 
    }];​

• then:信号的转换，将信号1转成信号2.
• error：也是放在订阅者的block里面处理。

signal如何取消订阅的block？

• 在一个completed或者error事件之后，订阅会自动移除（马上就会讲到）。
• 你还可以通过RACDisposable 手动移除订阅。如上所示。

3. 避免循环引用

[[self.searchText.rac_textSignal 
    map:^id(NSString *text) { 
        return [self isValidSearchText:text] ? 
            [UIColor whiteColor] : [UIColor yellowColor]; 
    }] 
    subscribeNext:^(UIColor *color) { 
        self.searchText.backgroundColor = color; 
 }];​

subscribeNext：block中使用了self来获取text field的引用。block会捕获并持有其作用域内的值。因此，如果self和这个信号之间存在一个强引用的话，就会造成循环引用。循环引用是否会造成问题，取决于self对象的生命周期。如果self的生命周期是整个应用运行时，比如说本例，那也就无伤大雅。但是在更复杂一些的应用中，就不是这么回事了。

改正方法如下所示：

__weak RWSearchFormViewController *bself = self; // Capture the weak reference 
 
[[self.searchText.rac_textSignal 
    map:^id(NSString *text) { 
        return [self isValidSearchText:text] ? 
            [UIColor whiteColor] : [UIColor yellowColor]; 
    }] 
    subscribeNext:^(UIColor *color) { 
        bself.searchText.backgroundColor = color; 
    }];​