引言
ReactiveCocoa为事件定义了一个标准接口，从而可以使用一些基本工具来更容易的连接、过滤和组合。从而减少代码量，处理比如action、delegate、KVO、callback等。
ReactiveCocoa结合了几种编程风格：
链式编程思想（Chain Programming）：关注于数据流和变化传播，是将多个操作通过点号(.)链接在一起成为一句代码,使代码可读性好。像这样调用a(1).b(2).c(3)
代表：masonry框架。
响应式编程（Reactive Programming）：关注于数据流和变化传播。不需要考虑调用顺序，只需要知道考虑结果，类似于蝴蝶效应，产生一个事件，会影响很多东西，这些事件像流一样的传播出去，然后影响结果，借用面向对象的一句话，万物皆是流。
代表：KVO运用。
函数式编程（Functional Programming）：使用高阶函数，例如函数用其他函数作为参数。
代表：ReactiveCocoa框架。
ReactiveCocoa 的导入：
platform :ios , '8.0'
use_frameworks!
target :RACTestDemo do
pod "ReactiveObjC"
end
ReactiveCocoa 的使用：
RACSiganl （信号类）
RACSignal *signal = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
// subscriber 是订阅者，这是一个协议，不是一个类。发送信号 @2
[subscriber sendNext:@2];
// 发送完成
[subscriber sendCompleted];
// RACDisposable:用于取消订阅或者清理资源，当信号发送完成或者发送错误的时候，就会自动触发它。
// 执行完Block后，当前信号就不在被订阅了。
return [RACDisposable disposableWithBlock:^{
NSLog(@"信号被销毁");
}];
}];
// singel信号类调用subscribeNext方法订阅信号。订阅之后才会激活这个信号，注意顺序！
[signal subscribeNext:^(id x) {
// block调用时刻：每当有信号发出数据，就会调用block.
NSLog(@"接收到数据:%@",x);
}];
打印结果
2018-02-01 10:37:48.767796+0800 RACTestDemo[3985:53574] 接收到数据:2
2018-02-01 10:37:48.767992+0800 RACTestDemo[3985:53574] 信号被销毁
解释：
1：RACSiganl（信号类）只是表示当数据改变时，信号内部会发出数据，它本身不具备发送信号的能力，而是交给内部一个订阅者subscriber去发出。
2：默认一个信号都是冷信号，就算是值改变了，但你没有订阅这个信号的话它也不会触发的，只有订阅了这个信号，这个信号才会变为热信号，值改变了才会触发。
RACSubject（信号提供者）
它自己可以充当信号，又能发送信号。
RACSubject *subject = [RACSubject subject];
[subject subscribeNext:^(id x) {
NSLog(@"第一个订阅者：%@", x);
}];
[subject subscribeNext:^(id x) {
NSLog(@"第二个订阅者：%@", x);
}];
[subject sendNext:@"发送信号"]; // 自己发送信号
打印结果
2018-02-01 11:04:24.675553+0800 RACTestDemo[4311:82953] 第一个订阅者：发送信号
2018-02-01 11:04:24.675747+0800 RACTestDemo[4311:82953] 第二个订阅者：发送信号
注意：
RACSubject只能先订阅再发送信号。
RACReplaySubject （信号重复提供者）
RACReplaySubject是RACSubject的子类，效果跟RACSubject一样。
RACReplaySubject *replaySubject = [RACReplaySubject subject];
[replaySubject sendNext:@"信号1"];
[replaySubject sendNext:@"信号2"];
[replaySubject subscribeNext:^(id x) {
NSLog(@"第一个订阅者：%@", x);
}];
[replaySubject subscribeNext:^(id x) {
NSLog(@"第二个订阅者：%@", x);
}];
打印结果
2018-02-01 11:15:55.261837+0800 RACTestDemo[4432:98719] 第一个订阅者：信号1
2018-02-01 11:15:55.262357+0800 RACTestDemo[4432:98719] 第一个订阅者：信号2
2018-02-01 11:15:55.262709+0800 RACTestDemo[4432:98719] 第二个订阅者：信号1
2018-02-01 11:15:55.262829+0800 RACTestDemo[4432:98719] 第二个订阅者：信号2
注意：
RACReplaySubject可以先发送信号，再订阅。
- map block（转换）
map操作通过block改变了事件的数据。map从上一个next事件接收数据，通过执行block把返回值改变传给下一个next事件。 - filter block（过滤）
filter操作通过block增加数据的过滤条件。
[[[[self.usernameTF rac_textSignal] map:^id(NSString *text) {
return @(text.length);
}] filter:^BOOL(NSNumber *value) {
return [value integerValue] >= 5;
}] subscribeNext:^(id x) {
DLog(@"%@", x);
}];
解释：
在上面的代码中，map以NSString为输入，取字符串的长度，返回一个NSNumber。再通过filter过滤掉小于5的数据，最后订阅者只能接收到的是字符串长度，并且大于等于5的值。
RACCommand
RACCommand类用于表示事件的执行，一般来说是在UI上的某些动作来触发这些事件。
- 比如点击一个按钮。
RACCommand的实例能够决定是否可以被执行，这个特性能反应在UI上，而且它能确保在其不可用时不会被执行。 - 通常，当一个命令可以执行时，会将它的属性
allowsConcurrentExecution设置为它的默认值：NO，从而确保在这个命令已经正在执行的时候，不会同时再执行新的操作。 - 命令执行的返回值是一个
RACSignal，因此我们能对该返回值进行next，completed或error。
这里指定登陆事件让SignalBlock执行
@weakify(self)
self.loginCommand = [[RACCommand alloc] initWithSignalBlock:^RACSignal *(id input) {
@strongify(self)
return [self loginWithUsername:self.usernameTF.text password:self.passwordTF.text];
}];
- (RACSignal *)loginWithUsername:(NSString *)username password:(NSString *)password {
return [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
// 登陆请求，在请求结果block发信号，在此处模拟
// 登陆成功 调用sendNext
// 登陆失败 调用sendError
dispatch_after(dispatch_time(DISPATCH_TIME_NOW, (int64_t)(3.0f * NSEC_PER_SEC)), dispatch_get_main_queue(), ^{
[subscriber sendNext:@"login"];
[subscriber sendCompleted];
NSLog(@"send login");
});
return nil;
}];
}
同时指定按钮的rac_command
self.loginBtn.rac_command = self.loginCommand;
执行结果的处理
// 判断当前的RACCommand的SignalBlock是否在执行，执行完之后会返回@(NO).
[self.loginBtn.rac_command.executing subscribeNext:^(id x) {
if ([x boolValue] == YES) {
NSLog(@"login...");
}
else {
NSLog(@"end login");
}
}];
// 需要执行的SignalBlock成功的时候返回的信号，他是在主线程执行的。
[self.loginBtn.rac_command.executionSignals subscribeNext:^(id x) {
NSLog(@"result：%@", x);
}];
// 执行command的时候获取的error都会通过这个信号发送
[self.loginBtn.rac_command.errors subscribeNext:^(id x) {
NSLog(@"error: %@", x);
}];
使用场景: 监听按钮点击，网络请求
ReactiveCocoa常见的方法：
1 代替代理: rac_signalForSelector：用于替代代理。
2 代替KVO : rac_valuesAndChangesForKeyPath:用于监听某个对象的属性改变。
3 监听事件: rac_signalForControlEvents:用于监听某个事件。
4 代替通知: rac_addObserverForName:用于监听某个通知。
5 监听文本框文字改变: rac_textSignal:只要文本框发出改变就会发出这个信号。
6 处理当界面有多次请求时，需要都获取到数据时，才能展示界面；rac_liftSelector:withSignalsFromArray:Signals:当传入的Signals(信号数组)，每一个signal都至少sendNext过一次，就会去触发第一个selector参数的方法。
