参考

• 官网：ReactiveCocoa
• cocoachina :ReactiveCocoa入门教程：第一部分
• InfoQ：ReactiveCocoa - iOS开发的新框架
• nshipster-Reactive?Cocoa
• ReactiveCocoa与Functional Reactive Programming
• 说说ReactiveCocoa 2
• 使用ReactiveCocoa实现iOS平台响应式编程
• ReactiveCocoa2实战
• ReactiveCocoa Tutorial – The Definitive Introduction: Part 1/2
• ReactiveCocoa Tutorial – The Definitive Introduction: Part 2/2
• MVVM Tutorial with ReactiveCocoa: Part 1/2
• MVVM Tutorial with ReactiveCocoa: Part 2/2

ReactiveCocoa介绍

• ReactiveCocoa（RAC）是一个在KVO的基础上建立Objective-C的框架，用于函数式反应型编程，它提供了组合和转化数据流的API。
• 它提供统一的消息传递机制，不再使用之前的比如action、delegate、target、KVO、callback等方式来处理以下事件比如按钮的点击，收到网络消息，属性的变化（通过KVO）或者用户位置的变化。
• ReactiveCocoa为事件定义了一个标准接口，从而可以使用一些基本工具来更容易的连接、过滤和组合。
• RAC的核心是Signal，对应的类为RACSignal，它其实是一个事件源，Signal会给它的订阅者（subscribers）发送一连串的事件。有三种事件：next，error和completed。Signal可以在error或completed事件发出前发出任意多的next事件。
• RAC为UIKit添加了很多类别来让我们可以订阅UI组件的事件，比如UITextField (RACSignalSupport)中的rac_textSignal会在文本域内容变化时发出next事件，事件包含的内容可以是类型，只要是对象就行，如果是一些数字，布尔值等字面量，可以用 @() 语法装箱成NSNumber。只要控件中有响应的在RAC中都有Extension，比如UIGestureRecognizer，UIAlertView不用delegate就可以知道点击哪个按钮等
  ReactiveCocoa结合了几种编程风格：
• 函数式编程（Functional Programming）：使用高阶函数，例如函数用其他函数作为参数。
• 响应式编程（Reactive Programming）：关注于数据流和变化传播。

ReactiveCocoa的使用

这次是在项目中使用的cocosPod方式，这种感觉简单，如果想直接导入ReactiveCocoa，详见官网。
在Podfile中加入下面一句话

pod 'ReactiveCocoa'

RAC中的类和方法

RACSignal是RACStream的子类。

RACStream

RACStream是一个抽象类，描述了值的流动，列举一下它比较常用的操作（Operations类别）：
- filter: 对RACStream中的事件内容进行过滤，返回一个过滤事件内容后的instancetype
- map: 会将事件中的数据转换成你想要的数据，返回一个转换事件内容后的instancetype
- flattenMap: 在map的基础上使其flatten，也就是当Signal嵌套（一个Signal的事件是另一个Signal）的时候，会将内部Signal的事件传递给外部Signal
- distinctUntilChanged 比较数值流中当前值和上一个值，如果不同，就返回当前值，简单理解为“流”的值有变化时反馈变化的值，求异存同。
- PS：instancetype是程序运行时对象的类型，有可能为RACStream，也可以为其子类RACSignal。正是因为这些操作事件的方法都会返回事件源对象相同的类型，事件可以被一连串的被这些方法修改，过滤等，这就形成了管道，管道中传递着事件，包含着value。

RACSignal

RACSignal中很多方法用于订阅事件，每个方法都会将类型为(void (^)(id x))的block作为参数，当事件发生时block中的代码会执行，例如 subscribeNext: 方法会传入一个block作为参数，当Signal的next事件发出后，block会接收到事件并执行。
RACSignal还有一些方法是对Signal做操作的,在RACSignal (Operations)类别中有详细的描述，比较常用的如下：
- combineLatest:reduce: 将一组Signal发出的最新的事件合并成一个Signal，每当这组Signal发出新事件时，reduce的block会执行，将所有新事件的值合并成一个值，并当做合并后Signal的事件发出去。这个方法会返回合并后的Signal。
PS：关于reduce的block中参数，其实是与combineLatest中数组元素一一对应的，这里RAC用了一个黑魔法，参看 RACBlockTrampoline
- doNext: 这个向Signal管道上添加添加副作用。它并不会改变事件，参数block也没有返回值，它返回一个执行了block的Signal，这样block中的副作用就被注入到了以前的Signal。
- then: 当一个订阅者被发送了completed事件后， then: 方法才会执行，订阅者会订阅 then: 方法返回的Signal，这个Signal是在block中返回的。这样优雅的实现了从一个Signal到另一个Signal的订阅。
- deliverOn: 参数为RACScheduler类的对象scheduler，这个方法会返回一个Signal，它的所有事件都会传递给scheduler参数所表示的线程，而以前管道上的副作用还会在以前的线程上。这个方法主要是切换线程。
- subscribeOn: 功能跟 deliverOn: 相同，但是它也会将副作用也切换到制定线程中。
- throttle: 它接收一个时间间隔interval作为参数，如果Signal发出的next事件之后interval时间内不再发出next事件，那么它返回的Signal会将这个next事件发出。也就是说，这个方法会将发送比较频繁的next事件舍弃，只保留一段“静默”时间之前的那个next事件，这个方法常用于处理输入框等信号（用户打字很快），因为它只保留用户最后输入的文字并返回一个新的Signal，将最后的文字作为next事件参数发出。
and 、 or 、 not NSNumber中Bool的与、或、非操作，将Signal发出的事件内容转化。
还可以根据方法（SEL类型）来创建Signal，每当该方法被调用时，Signal都会将此方法被传入的参数打包成 RACTuple 元组类型来发送next事件给它的接受者。 rac_signalForSelector: 和 rac_signalForSelector:fromProtocol: 这两个方法都能通过指定的方法来创建Signal。

RACSubscriber

RACSubscriber是一个协议，包含了向订阅者发送事件的方法。

[RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {             [subscriber sendNext:@(YES)];             [subscriber sendCompleted];        return nil;    }];

上面方法用于创建一个Signal，当Signal被订阅时， createSignal: 的参数block中的内容被执行。block的参数是一个实现RACSubscriber协议的对象，然后向这个订阅者发送了next事件（内容为NSNumber类型的@YES值）和completed事件。
PS：除此之外RACSubscriber还有 sendError: 和 didSubscribeWithDisposable: 两个方法。

RACDisposable

RACSignal (Subscription)类别中所有方法的返回值类型都是RACDisposable，它的 dispose 方法可以让我们手动移除订阅者。
例如：

RACSignal *backgroundColorSignal =  [self.searchText.rac_textSignal    map:^id(NSString *text) {      return [self isValidSearchText:text] ?        [UIColor whiteColor] : [UIColor yellowColor];    }]; RACDisposable *subscription =  [backgroundColorSignal    subscribeNext:^(UIColor *color) {      self.searchText.backgroundColor = color;    }]; // at some point in the future ...[subscription dispose];

注：当管道的订阅者全部被移除后，管道中的代码不会执行，包括三种事件参数block中的代码和诸如 doNext: 等副作用的block。可以简单理解为，当管道中的Signal没人订阅，它的事件就不会发出了。

RACCommand

RACCommand 通常用来表示某个Action的执行，比如点击Button。

RACScheduler

类似于GCD中的序列，是管理线程的类，负责RAC中让信号发出的事件华丽丽的在线程中穿梭，尤其是想更新UI必须在主线程中的时候，可以让事件直接从其他线程跳到主线程。此外RACScheduler也有优先级、延时等GCD中的特性。
解决引用循环
使用RAC会写大量的block，这就会涉及到引用循环的问题，而且会经常报出如此bug：Receive memory warning。一种普遍的解决办法是声明一个weak变量，并将self赋值给它，然后再block中使用这个weak变量，即typeof(self)weakSelf = self;。第二种是使用@weakify(self);及@strongify(self);这对宏在 RACEXTScope.h 中定义例如：

// typeof(self)weakSelf = self;// 法1
@weakify(self);// 定义了一个__weak的self_weak_变量
[[[_loginBtn rac_signalForControlEvents:UIControlEventTouchUpInside]flattenMap:^RACStream *(id value) {
@strongify(self);// 局域定义了一个__strong的self指针指向self_weak_
return [self signInSignal];
//return [weakSelf signInSignal];
}]subscribeNext:^(id x) {
[weakSelf IsloginSuccess:[x boolValue]];
}];

常用宏定义

• RAC() 可以将Signal发出事件的值赋值给某个对象的某个属性，其参数为对象名和属性名
• RACObserve() 参数为对象名和属性名，新建一个Signal并对对象的属性的值进行观察，当值变化时Signal会发出事件

PS：里面的部分课程也没怎么看。。囧