Pull-Driven 的数据流 RACSequence
原文
请您阅读原文Pull-Driven 的数据流 RACSequence ,作者 Draven。声明：本文只用做RAC相关知识点梳理，不做他用。
Push-Driven & Pull-Driven
推驱动（push-driven）和 拉驱动（pull-driven）。
RACSignal 和 RACSequence 都是 RACStream 的子类，它们不仅共享了来自父类的很多方法，也都表示数据流。
RACSignal 和 RACSequence 最大区别就是：
-
RACSignal是推驱动的，也就是在每次信号中的出现新的数据时，所有的订阅者都会自动接受到最新的值； -
RACSequence作为拉驱动的数据流，在改变时并不会通知使用当前序列的对象，只有使用者再次从这个 RACSequence 对象中获取数据才能更新，它的更新是需要使用者自己拉取的。
由于拉驱动在数据改变时，并不会主动推送给『订阅者』，所以往往适用于简化集合类对象等操作，相比于推驱动，它的适应场合较少。
Usage for RACSignal - RACSequence
RACSequence类簇
RACSequence - Subclasses
RACSequence 总共有九个子类。
操作 RACSequence
RACStream 为 RACSequence 提供了很多基本的操作，-map:、-filter:、-ignore:等等，因为这些方法的实现都基于 -bind:，而 -bind: 方法的执行是惰性的，所以在调用上述方法之后返回的 RACSequence 中所有的元素都是 unresolved 的，需要在访问之后才会计算并展开：
RACSequence *sequence = [@[@1, @2, @3].rac_sequence map:^id _Nullable(NSNumber * _Nullable value) {
return @(value.integerValue * value.integerValue);
}];
NSLog(@"%@", sequence); -> <RACDynamicSequence: 0x60800009ad10>{ name = , head = (unresolved), tail = (unresolved) }
NSLog(@"%@", sequence.eagerSequence); -> <RACEagerSequence: 0x60800002bfc0>{ name = , array = (1, 4, 9) }
除了从 RACStream 中继承的一些方法，在 RACSequence 类中也有一些自己实现的方法，比如说 -foldLeftWithStart:reduce: 方法：
- (id)foldLeftWithStart:(id)start reduce:(id (^)(id, id))reduce {
if (self.head == nil) return start;
for (id value in self) {
start = reduce(start, value);
}
return start;
}
使用简单的 for 循环，将序列中的数据进行『折叠』，最后返回一个结果：
RACSequence *sequence = @[@1, @2, @3].rac_sequence;
NSNumber *sum = [sequence foldLeftWithStart:0 reduce:^id _Nullable(NSNumber * _Nullable accumulator, NSNumber * _Nullable value) {
return @(accumulator.integerValue + value.integerValue);
}];
NSLog(@"%@", sum);
RACSequence 与 RACSignal
虽然 RACSequence 与 RACSignal 有很多不同，但是在ReactiveCocoa 中 RACSequence 与 RACSignal 却可以双向转换。
Transform Between RACSequence - RACSignal
分析其实现之前先看一下如何使用 -signal 方法将 RACSequence 转换成 RACSignal 对象的：
RACSequence *sequence = @[@1, @2, @3].rac_sequence;
RACSignal *signal = sequence.signal;
[signal subscribeNext:^(id _Nullable x) {
NSLog(@"%@", x);
}];
将 RACSequence 转换成 RACSignal
其实过程非常简单，原序列 @[@1, @2, @3] 中的元素会按照次序发送，可以理解为依次调用 -sendNext:，它可以等价于下面的代码：
RACSignal *signal = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber> _Nonnull subscriber) {
[subscriber sendNext:@1];
[subscriber sendNext:@2];
[subscriber sendNext:@3];
[subscriber sendCompleted];
return nil;
}];
[signal subscribeNext:^(id _Nullable x) {
NSLog(@"%@", x);
}];
-signal 方法的实现依赖于另一个实例方法 -signalWithScheduler:，它会在一个 RACScheduler 对象上发送序列中的所有元素：
- (RACSignal *)signal {
return [[self signalWithScheduler:[RACScheduler scheduler]] setNameWithFormat:@"[%@] -signal", self.name];
}
- (RACSignal *)signalWithScheduler:(RACScheduler *)scheduler {
return [[RACSignal createSignal:^(id<RACSubscriber> subscriber) {
__block RACSequence *sequence = self;
return [scheduler scheduleRecursiveBlock:^(void (^reschedule)(void)) {
if (sequence.head == nil) {
[subscriber sendCompleted];
return;
}
[subscriber sendNext:sequence.head];
sequence = sequence.tail;
reschedule();
}];
}] setNameWithFormat:@"[%@] -signalWithScheduler: %@", self.name, scheduler];
}
RACScheduler 并不是这篇文章准备介绍的内容，这里的代码其实相当于递归调用了 reschedule block，不断向 subscriber 发送 -sendNext:，直到 RACSequence 为空为止。
将 RACSignal 转换成 RACSequence
RACSignal *signal = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber> _Nonnull subscriber) {
[subscriber sendNext:@1];
[subscriber sendNext:@2];
[subscriber sendNext:@3];
[subscriber sendCompleted];
return nil;
}];
NSLog(@"%@", signal.toArray.rac_sequence);
运行上面的代码，会得到一个如下的 RACArraySequence 对象：
<RACArraySequence: 0x608000024e80>{ name = , array = (
1,
2,
3
) }
总结
相比于 RACSignal 来说，虽然 RACSequence 有很多的子类，但是它的用途和实现复杂度都少很多，这主要是因为它是 Pull-Driven 的，只有在使用时才会更新，所以我们一般只会使用 RACSequence 操作数据流，使用 map、filter、flattenMap 等方法快速操作数据。
