头文件定义

这几个方法需要子类去重写的

• 创建空流：+ (RACStream *)empty;

• 将单个值转换为流：+ (RACStream *)return:(id)value;

• 绑定值到块：- (RACStream *)bind:(RACStreamBindBlock (^)(void))block; 允许早期终止或闭包状态

• 连接流：- (RACStream *)concat:(RACStream *)stream; 连接两个相同类型的流

• 打包流：- (RACStream *)zipWith:(RACStream *)stream; 将多个流中的值组合成元组

• 映射和扁平化：- (RACStream *)flattenMap:(RACStream * (^)(id value))block; 应用于每个值并合并结果流

• flatten：将嵌套的数据流扁平化为单一数据流，并保留原始数据流的名字。

• map：对数据流中的每个值应用转换块（block），并设置转换后的新数据流名称。其中block参数不能为空。

• mapReplace 收一个对象object作为参数，并返回一个新的RACStream

• 过滤：- (RACStream *)filter:(BOOL (^)(id value))block; 过滤不符合条件的值

• 忽略特定值：-ignore: 接收一个参数 value，并返回一个新的 RACStream 对象。

• startWith:：此函数接收一个值，并创建一个新的流，在原有流开始前先发出这个值。

• 跳过值：- (RACStream *)skip:(NSUInteger)skipCount; 跳过指定数量的初始值

• 取前N个值：- (RACStream *)take:(NSUInteger)count; 取指定数量的初始值

• combinePreviousWithStart:reduce: 用于创建一个新的数据流，该流中的每个元素都是基于初始值start和前一个元素计算得出的结果。

• join:函数：将多个流组合成一个流，每个值被包装成元组。首次迭代时，将第一个流的值包装为单元素元组；后续迭代调用block方法组合当前流和新加入的流。

• zip:函数：通过join:函数实现对多个流的逐元素组合，并返回一个新的流。

• zip:reduce:函数：与zip:类似，但额外应用一个reduce操作来处理组合后的元素，最终生成新的流。

• concat:函数：将多个流依次连接成一个连续的流。

• 归约：- (RACStream *)reduceEach:(RACReduceBlock)reduceBlock; 对每个元组值进行归约处理

• 扫描：- (RACStream *)scanWithStart:(id)startingValue reduce:(id (^)(id running, id next))reduceBlock; 从左至右结合值生成新流

• scanWithStart:reduceWithIndex:：同样接收初始值和累积块，但累积块还接收当前元素索引，并返回处理后的新流。内部通过bind方法实现累积操作，并更新累积值和索引。

• takeUntilBlock:：返回一个新的流，该流会持续传递值直到predicate首次为真。

• takeWhileBlock:：通过取反predicate调用takeUntilBlock:来实现，返回一个流，当predicate为真时继续传递值。

• skipUntilBlock:：返回一个新的流，在predicate首次为真之前忽略所有值。

• skipWhileBlock:：通过取反predicate调用skipUntilBlock:来实现，返回一个流，在predicate为假之前忽略所有值。

• distinctUntilChanged：返回一个新的流，只在值发生变化时传递，相同值会被过滤掉。