ReactiveCocoa 是一个函数响应式编程（FRP）的框架。
一、导入框架
如果是纯OC项目，使用pod 'ReactiveObjC'导入OC版RAC即可。
如果是纯Swift项目，按照下图方式导入：
RAC-Swift.png
由于Swift要使用动态库，所以加入use_frameworks!这行代码。
二、信号类RACSignal
RACSiganl：信号类，一般表示将来有数据传递，只要有数据改变，信号内部接收到数据，就会马上发出数据。
信号类(RACSiganl)，只是表示当数据改变时，信号内部会发出数据，它本身不具备发送信号的能力，而是交给内部一个订阅者去发出。
-
获得一个信号的方式
1.单元信号
RACSignal *signal1 = [RACSignal return:@"value"];
RACSignal *signal2 = [RACSignal error:error];
RACSignal *signal3 = [RACSignal empty];
RACSignal *signal4 = [RACSignal never];
2.动态信号
RACSignal *signal5 = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
[subscriber sendNext:@1];
[subscriber sendNext:@2];
[subscriber sendError:error];
[subscriber sendCompleted];
return [RACDisposable disposableWithBlock:^{
}];
}];
3.Cocoa桥接
// 监测对象的该方法是否调用
RACSignal *signal6 = [view rac_signalForSelector:@selector(setFrame:)];
// 监测对象是否触发了该事件
RACSignal *signal7 = [button rac_signalForControlEvents:UIControlEventTouchUpInside];
// 对象将要释放时发出该信号
RACSignal *signal8 = [view rac_willDeallocSignal];
// 监测对象的某个属性是否变化，一旦变化就会发出信号
RACSignal *signal9 = RACObserve(view, backgroundColor);
4.信号变换
// 对信号每发出一个值进行处理，再返给信号
RACSignal *signal10 = [signal map:^id(NSString *value) {
return [value substringFromIndex:1];
}];
5.序列转换
// 集合也能被转换为信号进行操作
RACSignal *signal11 = collection.rac_sequence.signal;
-
订阅一个信号的方式
1.订阅方法
// 直接调用 subscribeNext 方法进行订阅
[signal11 subscribeNext:^(id x) {
NSLog(@"value %@", x);
} error:^(NSError *error) {
NSLog(@"error %@", error);
} completed:^{
NSLog(@"finished");
}];
2.绑定
// 将对象属性与信号值绑定
RAC(self.loginButton, enabled) = signal;
3.Cocoa桥接
// 两个信号都sendNext后才会调用selector
[view rac_liftSelector:@selector(data1:data2:) withSignalsFromArray:@[signal6, signal7]];
-
值操作
1.Map
// 把信号A中的值取出乘2后返回给信号B
RACSignal *signalB = [signalA map:^id(NSNumber *value) {
return @(value.integerValue * 2);
}];
2.MapReplace
// 把信号A中的值都替换为8
RACSignal *signalC = [signalA mapReplace:@8];
// 效果等同于
RACSignal *signalB = [signalA map:^id(id value) {
return @8;
}];
3.ReduceEach
// reduceEach与map类似，不过只有signalA包含的值是元组类型时才能用它
// 信号A中包含了N个元组，每个元组内有两个元素，使用 reduceEach 将每个元组中的两个数字取出并相加，返回给信号B
RACSignal *signalB = [signalA reduceEach:^id(NSNumber *first, NSNumber *second) {
return @(first.integerValue + second.integerValue);
}];
-
数量操作
1.Filter
// 过滤掉长度大于2的值
RACSignal *signalB = [signalA filter:^BOOL(NSString *value) {
return value.length > 2;
}];
2.Ignore
// 忽略为1的值
RACSignal *signalC = [signalA ignore:@1];
// 效果等同于
RACSignal *signalB = [signalA filter:^BOOL(id value) {
return ![@1 isEqual:value];
}];
// 忽略所有的值
- (RACSignal *)ignoreValues;
// 与上次的值不同时才发信号
- (RACSignal *)distinctUntilChanged;
// 只会收到一次信号
RACSubject *subject = [RACSubject subject];
[[subject distinctUntilChanged] subscribeNext:^(id x) {
NSLog(@"%@", x);
}];
[subject sendNext:@"HMJ"];
[subject sendNext:@"HMJ"];
[subject sendNext:@"HMJ"];
3.Take
// 取A的前两个值
RACSignal *signalB = [signalA take:2];
4.Take&Skip其它
// 取最后N次的值，会在信号完成后发送
- (RACSignal *)takeLast:(NSUInteger)count;
// 一直取值，直到block返回YES，如下例子
- (RACSignal *)takeUntilBlock:(BOOL (^)(id x))predicate;
// block返回YES才取值
- (RACSignal *)takeWhileBlock:(BOOL (^)(id x))predicate;
// 原理同上
- (RACSignal *)skipUntilBlock:(BOOL (^)(id x))predicate;
// 原理同上
- (RACSignal *)skipWhileBlock:(BOOL (^)(id x))predicate;
[[self.inputTextField.rac_textSignal takeUntilBlock:^BOOL(NSString *value) {
return [value isEqualToString:@"stop"];
}] subscribeNext:^(NSString *value) {
NSLog(@"current value is not `stop`: %@", value);
}];
5.StartWith
// 信号B以 Start 开头
RACSignal *signalB = [signalA startWith:@"Start"];
6.Repeat
// 不停地重复信号A
RACSignal *signalB = [signalA repeat];
7.Retry
// 如果返回错误则重新订阅，最多2次
RACSignal *signalB = [signalA retry:2];
8.副作用操作
RACSignal *signalB = [signalA map:^id(id value) {
// do some thing
return value;
}];
RACSignal *signalC = [signalA doNext:^(id x) {
// do some thing
}];
- (RACSignal *)doError:(void (^)(NSError *error))block;
- (RACSignal *)doCompleted:(void (^)(void))block;
- (RACSignal *)initially:(void (^)(void))block;
- (RACSignal *)finally:(void (^)(void))block;
9.Collect
// 把信号A的值收集为数组
RACSignal *signalB = [signalA collect];
10.Aggregate
// 汇聚，前一次的运算结果为running，下次的信号值为next
// 如果signalA的值依次为1、2、3、4、5，汇聚之后就是25
RACSignal *signalB = [signalA aggregateWithStart:@0 reduce:^id(NSNumber *running, NSNumber *next) {
return @(running.integerValue + next.integerValue);
}];
11.Scan
// 使用Aggregate时，如果A不停止，B就永远不会返回值
// 而使用Scan就不会有这个弊端，每次运算结果都会返回
RACSignal *signalB = [signalA scanWithStart:@0 reduce:^id(NSNumber *running, NSNumber *next) {
return @(running.integerValue + next.integerValue);
}];
-
时间操作
1.Scheduler
// 比较准确的时间操作，可代替NSTimer
- (RACSignal *)interval:(NSTimeInterval)interval
onScheduler:(RACScheduler *)scheduler;
- (RACSignal *)interval:(NSTimeInterval)interval
onScheduler:(RACScheduler *)scheduler
withLeeway:(NSTimeInterval)leeway;
2.Delay
// 准确度比 Scheduler 低
RACSignal *signalB = [signalA delay:1];
3.Throttle
// 阀门时间，设置时间内如果没有新的信号才返回值，否则就重新开始计时
RACSignal *signalB = [signalA throttle:1];
-
组合操作
1.Concat
// 按信号顺序合并信号，第一个信号如果不停止，第二个信号就永远无法开始接收
// 可用于多网络请求时，返回数据需要按顺序拼接的场景
RACSignal *signalC = [signalA concat:signalB];
2.Merge
// 将多个信号合并成一个信号，按照发送值的顺序来合并，属于无序合并
RACSignal *signalC = [signalA merge:signalB];
RACSignal *signalC = [RACSignal merge:@[signalA, signalB]];
RACSignal *signalC = [RACSignal merge:RACTuplePack(signalA, signalB)];
3.Zip
// 合并两个信号的最新值为元组，只有两个信号都有新值时才会合并
RACSignal *signalC = [signalA zipWith:signalB];
RACSignal *signalC = [RACSignal zip:@[signalA, signalB]];
RACSignal *signalC = [RACSignal zip:RACTuplePack(signalA, signalB)];
4.CombineLatest
// 与zip相似，都是合并两个信号的值为元组，不过combineLatest只需一个信号值改变就能合并
RACSignal *signalC = [signalA combineLatestWith:signalB];
RACSignal *signalC = [RACSignal combineLatest:@[signalA, signalB]];
5.Sample
// B触发时才去获取A的实时值
RACSignal *signalC = [signalA sample:signalB];
6.TakeUntil
// 获取信号A，B开始就停止
RACSignal *signalC = [signalA takeUntil:signalB];
7.TakeUntilReplacement
// 获取信号A，B开始就停止获取A，转而获取B，直到B停止
RACSignal *signalC = [signalA takeUntilReplacement:signalB];
-
订阅高阶信号
如果信号中包含了信号，它就是高阶信号。
下面代码中信号highOrderSignal中包含了信号，所以它是高阶信号。
RACSignal *signal = @[@1, @2, @3].rac_sequence.signal;
RACSignal *highOrderSignal = [signal map:^id(id value) {
return [RACSignal return:value];
}];
[highOrderSignal subscribeNext:^(RACSignal *aSignal) {
[aSignal subscribeNext:^(id x) {
NSLog(@"%@", x);
}];
}];
将信号的值转变成信号叫做信号的升阶，将信号中的信号转变成值叫做信号的降阶。
-
降阶操作
1.SwitchToLatest
switchToLatest能够对高阶信号进行降阶，它总是订阅最新的信号。
RACSignal *signalB = [signalA switchToLatest];
// 如下示例，订阅后最终收到的值为@"1"、@"11"、@"2"。
// 没有收到@"111"是因为它被发送时，sub1已经不是最新信号了
// 要注意，最新信号发生error会中断latest信号
RACSubject *signalOfSignals = [RACSubject subject];
RACSubject *sub1 = [RACSubject subject];
RACSubject *sub2 = [RACSubject subject];
RACSignal *latest = [signalOfSignals switchToLatest];
[latest subscribeNext:^(id x) {
NSLog(@"***** %@",x);
}];
[signalOfSignals sendNext:sub1];
[sub1 sendNext:@"1"];
[sub1 sendNext:@"11"];
[signalOfSignals sendNext:sub2];
[sub2 sendNext:@"2"];
[sub1 sendNext:@"111"];
2.If/then/else
如果 signalA 的值为 true 取 signalTrue 的值，否则取 signalFalse 的值。
RACSignal *signalB = [RACSignal if:signalA
then:signalTrue
else:signalFalse];
3.Flatten
flatten进行的降阶与switchToLatest不同，它能够获取所有的值。
RACSignal *signalB = [signalA flatten];
方法- (RACSignal *)flatten:(NSUInteger)maxConcurrent中，maxConcurrent表示最大并发数。比如 flatten:2 表示当前最多只能对信号中的2个信号进行降阶操作，如果有新的信号产生，先进行等待，等到前面有信号结束之后才加入。
所以 Flatten 类似于 Merge，Flatten:1 类似于 Concat。
4.FlattenMap
高阶信号可以用flattenMap进行映射，在block中再对映射出的低阶信号进行映射，最后返回的信号就是降维后的信号。
-
冷信号与热信号
热信号：
热信号是主动的，即使你没有订阅事件，它仍然会不断推送。
热信号可以有多个订阅者，是一对多，信号可以与订阅者共享信息。
冷信号：
冷信号是被动的，只有当你订阅的时候，它才会发送消息。
冷信号只能一对一，当有新的订阅者时，消息会重新完整发送。
在 RAC 中，RACSubject及其子类是热信号，RACSignal除RACSubject以外的信号是冷信号。
1.热信号
RACSubject需要先订阅再发送：
RACSubject *subject = [RACSubject subject];
[subject subscribeNext:^(id x) {
//
} error:^(NSError *error) {
//
} completed:^{
//
}];
[subject sendNext:@1];
[subject sendNext:@2];
[subject sendNext:@3];
[subject sendCompleted];
RACReplaySubject可先发送再订阅：
RACReplaySubject *subject = [RACReplaySubject replaySubjectWithCapacity:1];
[subject sendNext:@1];
[subject sendNext:@2];
[subject sendCompleted];
[subject subscribeNext:^(id x) {
//
}];
RACReplaySubject是具备快速回播的信号，同时它还能控制“历史值”的数量。
网友评论