三.ReactiveCocoa代码实践之-更多思考

1. RACObserve()宏形参写法的区别

之前写代码考虑过 RACObserve(self.timeLabel , text) 和 RACObserve(self , timeLabel.text) 的区别。 因为这两种方法都是观察self.timeLabel.text的属性，并且都能实现功能。估计是作者原本用的其中一种后来对另一种也提供了支持，究竟有什么区别哪一种写法更好？

点进去看RACObserve的源码 大多都是方法调用，一层一层点进去最后来到这个方法。

- (RACDisposable *)rac_observeKeyPath:(NSString *)keyPath options:(NSKeyValueObservingOptions)options observer:(__weak NSObject *)weakObserver block:(void (^)(id, NSDictionary *, BOOL, BOOL))block

这个方法里面把逗号后面的keypath通过“.” 进行分割成了一个数组。 并且得到三个属性

BOOL keyPathHasOneComponent = (keyPathComponents.count == 1);
NSString *keyPathHead = keyPathComponents[0];
NSString *keyPathTail = keyPath.rac_keyPathByDeletingFirstKeyPathComponent;

这里会取到keypatch的头和去掉头的部分，并且会在下面方法内部自己调用自己

// Adds the callback block to the remaining path components on the value. Also
// adds the logic to clean up the callbacks to the firstComponentDisposable.
void (^addObserverToValue)(NSObject *) = ^(NSObject *value) {RACDisposable *observerDisposable = [value rac_observeKeyPath:keyPathTail options:(options & ~NSKeyValueObservingOptionInitial) observer:weakObserver block:block];[firstComponentDisposable() addDisposable:observerDisposable];
};

并且把keyPathTail 作为keypatch传进去了，就是递归调用，每一次进来都会切掉第一个元素，直到BOOL keyPathHasOneComponent 这个值等于yes。从这个角度看用RACObserve(self , timeLabel.text) 这种写法会引发递归调用，性能不如RACObserve(self.timeLabel.text)。

更多RAC宏相关知识可见这篇 ：http://blog.sunnyxx.com/2014/03/06/rac_1_macros/

2.集合操作

假设现在有一个需求，有一串密码的数组，我们判断密码长度小于6位就是太短，就会系统内部抛出一个消息：XXX密码太短不合格。采用RAC的写法会比常规写法方便，一个过滤一个自定义然后直接返回。

NSArray *pwds = @[@"567887",@"89877",@"789",@"7899000"];
RACSequence *results = [[pwds.rac_sequencefilter:^ BOOL (NSString *pwd) {return pwd.length < 6;}]map:^id(NSString *pwd) {return [[pwd mutableCopy]stringByAppendingString:@"密码太短不合格"];}];
NSLog(@"%@",results.array);

中间filter方法的block内代码会在下面results.array代码执行时才会执行， 相当于是有了个订阅者才会执行。这一点和RACSignal很像，因为signal 和 sequence 都是streams，他们共享很多相同的方法signal是push驱动的stream，sequence是pull驱动的stream。

如果相从RACSequence对象中取出其他属性时进行操作也可以用如下方法

RACSequence *s = [RACSequence sequenceWithHeadBlock:^id{return @"自定义操作";
} tailBlock:^RACSequence *{return [RACSequence new];
}];
NSLog(@"%@",s.head);
NSLog(@"%@",s.tail);

两个block分别会在指定属性被调用时才会执行，注意head就是sequence的第一个元素，而tail是除去第一个元素的剩余所有，所以还是一个sequence。(董铂然博客园)

3.信号实现游戏技能释放

假设现在需要用RAC模拟一个街机里放爆气技能的方法。 按下了指定的按钮顺序下前下前拳就会释放绝招。

首先需要将各个按钮连线，并设置一个信号来监听所有按键单独信号的并集，捕捉到每个按钮的title。

// 把六个按键的信号合并
RACSignal *comboSignal = [[RACSignal merge:@[[self.topBtn rac_signalForControlEvents:UIControlEventTouchUpInside],[self.bottomBtn rac_signalForControlEvents:UIControlEventTouchUpInside],[self.leftBtn rac_signalForControlEvents:UIControlEventTouchUpInside],[self.rightBtn rac_signalForControlEvents:UIControlEventTouchUpInside],[self.BBtn rac_signalForControlEvents:UIControlEventTouchUpInside],[self.ABtn rac_signalForControlEvents:UIControlEventTouchUpInside]]]
map:^id(UIButton *btn) {return btn.currentTitle;
}];

然后对这个信号源进行buffer操作，把每三秒收到的所有按键信息都捕获到，并进行判断和后继操作

// 设置触发爆气条件
NSString *comboCode = @"下前下前拳";
// 实际操作
RACSignal *canAction = [[[comboSignal bufferWithTime:3 onScheduler:[RACScheduler mainThreadScheduler]] map:^id(RACTuple *value) {return [[value allObjects] componentsJoinedByString:@""];
}] map:^id(NSString *value) {return @([value containsString:comboCode]);
}];
// 调用combo:方法就是技能释放
[self rac_liftSelector:@selector(combo:) withSignalsFromArray:@[canAction]];

上面的代码可以实现预计的功能，只要你能在三秒的buffer内按出指定的按键就能释放。但是用这个方法中间也有一个问题：设置了buffer3秒后这个block里面每隔三秒才会来到一次，也就是说如果你在0.5秒内就按出了技能，那也需要再等2.5秒才能放出技能，显然这个在实战中是不能接受的。

于是尝试了其他的实现思路，尝试了takeLast:及takeUntilBlock:及scanWithStart: 等方法都不是很合适，最后使用了aggregateWithStart:  达到了需求的目的。

// 设置触发爆气条件
NSString *comboCode = @"下前下前拳";
// 实际操作
_time = [[[NSDate alloc] init] timeIntervalSince1970];
[[comboSignal aggregateWithStart:@"" reduce:^id(NSString* running, NSString* next) {if (([[[NSDate alloc] init] timeIntervalSince1970] - _time) < 3){NSString *str = [NSString stringWithFormat:@"%@%@",running,next];return [str containsString:comboCode]?[self combo]:str;}_time = [[[NSDate alloc] init] timeIntervalSince1970];return str.length < combo.length ? str : [str subStringFromIndex:str.length - comboCode.length];
}]subscribeNext:^(id x){
}];

使用这段代码可以在满足之前条件的前提下，并且按钮一按完马上触发技能。

aggregateWithStart：reduce：的第一个参数是初始值，第二个参数是一个block，这个block的返回值就是下一次来到这个block的 running参数。我在这个block的循环中做的操作有：

1.对时间进行delta计算，如果距离上一次时间节点大于3秒，刷新时间节点重新计时。 str小于5则返回，大于5则截取后五位返回。

2.如果小于3秒则把每次按键信息聚合成一个字符串并判断是否包含技能触发代码。

3.满足的话触发技能，技能方法的内部也刷新了时间节点，并截取running（保留最后4位，防止上一个循环结束和下一个循环开始所满足的条件）。不满足则将这个字符串继续返回。

虽然代码写的不是很好看，但是功能是实现了，感觉有点别扭，因为函数式编程倡导的是引用透明无副作用，所以上面需要记录值和成员变量的做法很明显就不适合用RAC了，应该还会有更好的方法实现。

4.其他RAC操作

1)映射：flattenMap，Map用于把源信号内容映射成新的内容

2)组合：concat:按一定顺序拼接信号，当多个信号发出的时候，有顺序的接收信号

3）`then`:用于连接两个信号，当第一个信号完成，才会连接then返回的信号

4）`merge`:把多个信号合并为一个信号，任何一个信号有新值的时候就会调用

5）`combineLatest`:将多个信号合并起来，并且拿到各个信号的最新的值,必须每个合并的signal至少都有过一次sendNext，才会触发合并的信号。

6）`reduce`聚合:用于信号发出的内容是元组，把信号发出元组的值聚合成一个值

7）filter:过滤信号，使用它可以获取满足条件的信号.

8) ignore:忽略完某些值的信号.

9) distinctUntilChanged:当上一次的值和当前的值有明显的变化就会发出信号，否则会被忽略掉

10) take:从开始一共取N次的信号

11)takeLast:取最后N次的信号,前提条件，订阅者必须调用完成，因为只有完成，就知道总共有多少信号

12)takeUntil:(RACSignal *):获取信号直到某个信号执行完成

13）skip:(NSUInteger):跳过几个信号,不接受

14）switchToLatest:用于signalOfSignals（信号的信号），有时候信号也会发出信号，会在signalOfSignals中，获取signalOfSignals发送的最新信号

15）doNext: 执行Next之前，会先执行这个Block

16）doCompleted: 执行sendCompleted之前，会先执行这个Block

17）deliverOn: 内容传递切换到制定线程中，副作用在原来线程中,把在创建信号时block中的代码称之为副作用

18）subscribeOn: 内容传递和副作用都会切换到制定线程中

19）interval 定时：每隔一段时间发出信号

20）delay 延迟发送next。

21） 代替代理:

• rac_signalForSelector：用于替代代理。

22） 代替KVO :

• rac_valuesAndChangesForKeyPath：用于监听某个对象的属性改变。

23） 监听事件:

• rac_signalForControlEvents：用于监听某个事件。

24） 代替通知:

• rac_addObserverForName:用于监听某个通知。

25） 监听文本框文字改变:

• rac_textSignal:只要文本框发出改变就会发出这个信号。

26） 处理当界面有多次请求时，需要都获取到数据时，才能展示界面

• rac_liftSelector:withSignalsFromArray:Signals:当传入的Signals(信号数组)，每一个signal都至少sendNext过一次，就会去触发第一个selector参数的方法。
• 使用注意：几个信号，参数一的方法就几个参数，每个参数对应信号发出的数据

RAC曾经被冠以 学习成本搞，可读性差，debug的噩梦等不良评价，但随着近几年的演变已逐渐被企业级项目所接受，并且成为函数响应式编程主流框架。RAC用人越来越多，随笔和博客也越来越多，学习的门槛已经大大降低。 并且我觉得初学者没有必要一开始就把所有操作和概念都弄懂，可以从简单的用法开始一步步的接触高阶语法，这样会更容易接受。