文章系列
《ReactiveCocoa 概述》
《RACSignal》
《RACDisposable》
《RACSubject、RACReplaySubject(内附冷信号和热信号的区别)》
《集合RACTuple、RACSequence》
《RAC 中的通知、代理、KVO, 基本事件、方法的监听》
《rac_liftSelector》
《RACMulticastConnection》
《RACCommand》
《RAC - 核心方法bind》
《RAC - 定时器》
《RACScheduler》
《RAC - 点击获取验证码 demo》
《RAC - 映射(Map & flattenMap)》
《RAC信号操作解释合集》
《RAC - 信号的生命周期》
mapReplace (替换)
将信号中的内容全部替换为指定的
- (__kindof RACStream *)mapReplace:(nullable id)object;
reduceEach (变换)
信号必须发送的是一组值(RACTuple),通过reduceBlock接收一组值,然后处理返回一个值
- (__kindof RACStream *)reduceEach:(RACReduceBlock)reduceBlock;
filter (过滤)
fillter 返回一个BOOL变量,当BOOL为true的使用才会返回信号, 否则就过滤掉了.
- (__kindof RACStream<ValueType> *)filter:(BOOL (^)(ValueType _Nullable value))block;
ignore (忽略)
忽略信号中的某些值
- (RACSignal<ValueType> *)ignore:(nullable ValueType)value;
take (提前终止)
实现原理是bind; 后面接数字,取前多少个值, 阻断信号的执行, 直接停止订阅了.
- (__kindof RACStream<ValueType> *)take:(NSUInteger)count;
skip (跳过)
实现原理是bind; 跳过前几次的值
- (__kindof RACStream<ValueType> *)skip:(NSUInteger)skipCount;
concat (连接)
把一组信号串联起来,前面一个信号complete,后面一个信号才开始发挥作用, 连接在后面, 形成一个新的信号.
注: 不论哪个信号存在error , 到第一个error 就终止连接.
+ (__kindof RACStream<ValueType> *)concat:(id<NSFastEnumeration>)streams;
startWith (在前面增加量)
实现原理是concat, 在信号之前增加一个值, 也就是说在源信号之前先发送一个值.
- (__kindof RACStream<ValueType> *)startWith:(nullable ValueType)value;
repeat (重复增加)
当信号发送complete的时候,重新订阅, 反复增加原始数据.
注: RACSignal 自己的方法. 若repeat 一个错误信息, 只repeat 一次就终止了.
- (RACSignal *)repeat ;
retry (反复重新添加)
发送error事件之后重试,重新订阅, 即越到错误越来越勇, 反复订阅, 反复开始, 一直不成功, 一直retry.
- (RACSignal<ValueType> *)retry;
- (RACSignal<ValueType> *)retry:(NSInteger)retryCount;
doNext (副作用操作)
作用: 用来往信号注入side effects, 显示标记side effects的方法，在每次信号subscribeNext之前执行.
不改变原value , 只是想干点啥, 比如打印.
- (RACSignal *)doNext:(void (^)(id x))block ;
collect (收集)
把信号所有的数据都存到一个数组里面, 等到complete事件的时候，把这个数组发出去. 原理是: 一连串操作的集合->经过 aggregateWithStartFactory操作、defer操作、scanWithStart、bind等等(文中都有解释)总之, 它的大致原理是：1、scanWithStart，前面我们解释过，这个是使用block合并信号的前一个值和下一个值，返回一个新值的操作，初始值我们指定一个可变数组，block的操作是把下一个值添加到这个数组中来；2、takeLast操作来保证原始信号结束之后（complete）发送最近的一个结果。
注:要确保调用collect 的信号可以完结, 否则得到的新信号将成为never 信号.
- (RACSignal*)collect;
aggregateWithStartFactory (加和操作)
- 伪递归操作
scanWithStart (扫描)
作用: 信号内部信号全部扫描一遍, 做操作; 也就是使用reduceBlock从左到右合并receiver包含的值.
startingValue是第一个left值,信号的第一个值是right值,使用block进行合并,返回新值,以后的left是上一次合并之后的值,right是next的值,效果的叠加.
- (RACSignal *)scanWithStart:(nullable id)startingValue reduce:(id _Nullable (^)(id _Nullable running, ValueType _Nullable next))reduceBlock RAC_WARN_UNUSED_RESULT;
throttle (阀门)
每次发送的数据，都经过interval的间隔之后才发出。在interval时间内发送的所有信号只有最后一个数据被发送，前面的都会被抛弃。
- (RACSignal<ValueType> *)throttle:(NSTimeInterval)interval RAC_WARN_UNUSED_RESULT;
merge (信号投射)
合并的信号的意思是，每个原始信号sendNext都会被当作返回信号的一次值发送(基于bind，绑定).
按照时间顺序平铺投射到一个信号上, 受线程影响.
- (RACSignal *)merge:(RACSignal *)signal
zip (拉链)
类方法。它合并一组信号。必须任何一个信号都发送了一次值，合并后的信号才会把这几个信号的同一批次的值封装为RACTuple发送出去。例如合并两个信号，第一个信号发了两次1，2，第二个没发送，那么不会有信号发出；如果第二个信号发送一次3，那么合并之后的信号会发送一个RACTuple（1，3），除非第二个信号在发送第二个值，第一个信号发送的第二个值才会被一起包装作为一次信号发送出去。
+ (RACSignal<RACTuple *> *)zip:(id<NSFastEnumeration>)signals
combineLatest
两个信号是否产生最新值, 打成tuple, 先结束的就终止了.
+ (RACSignal<RACTuple *> *)combineLatest:(id<NSFastEnumeration>)signals
takeUntil (通过信号B 来结束信号A)
原始信号一直发送信号，直到，替代的信号发出事件，原始信号终止.
例: 当信号B有值时,信号A 终止订阅.
switchToLatest
原始信号必须是发送信号的信号（sendNext：(RACSignal)…），发送的信号会被订阅，直到发送下一个信号，前一个被发送的信号就终止订阅，方法的作用是，每次订阅最新的信号。和map一起往往被认为是替代flattenMap的方案.
.End
