RAC使用函数响应式编程的思想，将我们平时用到的按钮点击事件、KVO、代理、通知等等封装起来，处理业务逻辑的代码放到一起，使代码更加的简洁、高内聚、低耦合，那么我们来看看它的具体使用。
一、RAC的基本使用
RAC和KVO
//使用RAC来监听字符串myString的变化
[RACObserve(self, myString) subscribeNext:^(id _Nullable x) {
NSLog(@"myString值发生变化后的新值：%@",x);
}];
一句代码就可以代替KVO,代码和功能在一起，写起来方便，简单易读。
-
RACObserve(TARGET, KEYPATH):RAC提供的宏定义，用来监听值的变化，返回RACSignal类型的信号，有了这个宏定义返回的信号，就可以订阅该信号，变化后的值。 -
subscribeNext::订阅信号，只有订阅了信号才可以收到值的变化。
RAC和通知
//监听键盘弹出的通知
[[[NSNotificationCenter defaultCenter] rac_addObserverForName:UIKeyboardWillShowNotification object:nil] subscribeNext:^(NSNotification * _Nullable x) {
//处理接收到的通知
NSLog(@"%@",x);
}];
rac_addObserverForName: object:：也可以添加开发中自己注册的通知，添加监听通知的方法，写在NSNotificationCenter分类中。RAC中有很多的分类实现不同的方法。
RAC和代理
//添加UITextFieldDelegate代理方法textFieldDidBeginEditing:信号
[[self rac_signalForSelector:@selector(textFieldDidBeginEditing:) fromProtocol:@protocol(UITextFieldDelegate)] subscribeNext:^(RACTuple * _Nullable x) {
//RACTuple：元组类型
NSLog(@"%@",x);
}];
//实现代理
self.textField.delegate = self;
rac_signalForSelector:fromProtocol:添加代理方法信号。
- 值得注意的是，接收订阅信号的参数是
RACTuple元组类型，熟悉swift语法的话对元组类型一定不陌生，元组是把多个值组合成一个复合值。元组内的值可以是任意类型，并不要求是相同类型。以下是上面代码接受到信号的打印信息，可以看一下元组是什么样子的：
<RACTuple: 0x6000018a5960> (
<UITextField: 0x7f966fd6b3d0; frame = (72 219; 270 34); text = ''; opaque = NO; autoresize = RM+BM; gestureRecognizers = <NSArray: 0x60000143dce0>; layer = <CALayer: 0x600001ad9240>>,
)
UIButton
//按钮点击信号
@weakify(self);//防止循环引用的问题
[[self.myButton rac_signalForControlEvents:UIControlEventTouchUpInside] subscribeNext:^(__kindof UIControl * _Nullable x) {
@strongify(self);//暂时强引用
//接收到点击信号的响应,
if(self.textField.text.length == 0) {
NSLog(@"请先输入名称");
}else {
//...
}
}];
rac_signalForControlEvents ::UIButton的分类方法，产生点击信号。
- 在订阅信号中进行
UI的绑定，这种思想在MVVM+RAC的架构中非常重要，MVVM中通过block回调可以完成ViewModel向UI层数据传递，使用rac进行UI绑定，就可以完成UI层向ViewModel层的数据传输，从而实现双向绑定。
UITextField
//输入框文字改变信号
[self.textField.rac_textSignal subscribeNext:^(NSString * _Nullable x) {
//打印当前textField的text
NSLog(@"%@",x);
}];
rac_textSignal:输入框输入的文字发生改变的信号，订阅这个信号可以处理文字长度，输入格式等。
手势
UITapGestureRecognizer *tap = [[UITapGestureRecognizer alloc] init];
self.label.userInteractionEnabled = YES;
[self.label addGestureRecognizer:tap];
[tap.rac_gestureSignal subscribeNext:^(__kindof UIGestureRecognizer * _Nullable x) {
NSLog(@"%@",x);
}];
rac_gestureSignal：手势触发信号。
序列 sequence
数组遍历
NSArray *nameArray = @[@"Niki",@"Pan",@"Ding",@"Jiao"];
//数组遍历
[nameArray.rac_sequence.signal subscribeNext:^(id _Nullable x) {
NSLog(@"%@",x);//依次打印数组元素
}];
NSDictionary *dict = @{@"name":@"Niki",@"age":@"18",@"number":@"999"};
//遍历字典
[dict.rac_sequence.signal subscribeNext:^(id _Nullable x) {
//元组类型
NSLog(@"%@",x);
//RACTwoTuple继承自RACTuple，表示有两个值的元组
RACTwoTuple *tuple = (RACTwoTuple *)x;
NSLog(@"key == %@ , value = %@",tuple[0],tuple[1]);
}];
集合类型在RAC中都封装成了序列，通过访问rac_sequence属性得到序列。
二、RAC中的高阶函数
-
信号映射：
map和flattenMap,把原有信号中的值映射成新的值。
-
map:方法返回依旧是一个信号RACSignal类型，如下代码，将rac_textSignal信号中的字符串经过map映射处理成字符串的长度。注意：map的block中必须要返回对象类型的数据。
[[self.passField.rac_textSignal map:^id _Nullable(NSString * _Nullable value) {
return @(value.length);
}] subscribeNext:^(id _Nullable x) {
NSLog(@"映射后的新值：%@",x);//输出字符串长度
}];
-
flattenMap:把源信号的内容映射成一个新的信号，信号可以是任意类型。
[[self.passField.rac_textSignal flattenMap:^__kindof RACSignal * _Nullable(NSString * _Nullable value) {
//返回RACSignal类型
return [RACReturnSignal return:@(value.length)];
}] subscribeNext:^(id _Nullable x) {
NSLog(@"映射后的新值：%@",x);
}];
-
信号过滤：
filter,ignore,distinctUntilChanged
-
filter：获取满足条件的信号 -
ignore：内部调用了filter，忽略掉ignore传入的参数。 -
distinctUntilChanged：跟函数名字面意思一样，直到值和上一次有区别才会发出信号，忽略的是和上一次值一样的信号。经常用于UI的刷新，值发生变化的时候才刷新。
下面依次来看代码示例：
//filter
[[self.passField.rac_textSignal filter:^BOOL(NSString * _Nullable value) {
//输入字符串长度大于3
return value.length > 3;
}] subscribeNext:^(id _Nullable x) {
//获取到输入字符串长度大于3的信号
//当输入字符串长度大于3才会在这里打印
NSLog(@"%@",x);
}];
//ignore
[[self.passField.rac_textSignal ignore:@"n"] subscribeNext:^(NSString * _Nullable x) {
NSLog(@"%@",x);//输入n，这里收不到信号
}];
//distinctUntilChanged
RACSubject *subject = [RACSubject subject];
[[subject distinctUntilChanged] subscribeNext:^(id x) {
NSLog(@"%@", x);//收到的信号依次是a b c,第三次发送的b被忽略了
}];
// 发送信号
[subject sendNext:@"a"];
[subject sendNext:@"b"];
[subject sendNext:@"b"];
[subject sendNext:@"c"];
-
信号合并：
combineLatest,reduce,merge,zipWith
-
combineLatest：将多个信号合并起来，并且拿到各个信号的最新值,必须每个合并的signal至少都有过一次sendNext，才会触发合并的信号。 -
reduce：把combineLatest的元组聚合成一个值发送出去，相当于对combineLatest的进一步加工，必须每个合并的signal至少都有过一次sendNext，才会触发合并的信号。 -
merge：把多个信号合并成一个信号，任何一个信号发送数据，都能监听到。 -
zip：把最近发出的信号包装成元组发出。当每个信号同事发出信号内容，才会发出信号。
//combineLatest
//创建三个信号
RACSubject *s1 = [RACSubject subject];
RACSubject *s2 = [RACSubject subject];
RACSubject *s3 = [RACSubject subject];
//合并三个信号
RACSignal *combineSg = [RACSignal combineLatest:@[s1,s2,s3]];
//订阅合并信号
[combineSg subscribeNext:^(id _Nullable x) {
//当三个信号都有一次发送的时候才能收到聚合信号
//这里收到是一个元组类型，三个元素分别为三个信号的最新值
NSLog(@"%@",x);
}];
//发送信号
[s1 sendNext:@"a"];
[s2 sendNext:@"1"];
[s3 sendNext:@"!"];
[s1 sendNext:@"b"];
[s2 sendNext:@"2"];
[s3 sendNext:@"@"];
[s1 sendNext:@"c"];
[s2 sendNext:@"3"];
[s3 sendNext:@"#"];
//reduce
RACSubject *s1 = [RACSubject subject];
RACSubject *s2 = [RACSubject subject];
RACSubject *s3 = [RACSubject subject];
RACSignal *reduceSg = [RACSignal combineLatest:@[s1,s2,s3] reduce:^(id value1,id value2,id value3){
//value1 value2 value3为三个信号的最新值
return [NSString stringWithFormat:@"%@,%@,%@",value1,value2,value3];
}];
//订阅聚合信号
[reduceSg subscribeNext:^(id _Nullable x) {
NSLog(@"%@",x);
}];
//发送信号
[s1 sendNext:@"a"];
[s2 sendNext:@"1"];
[s3 sendNext:@"!"];
[s1 sendNext:@"b"];
[s2 sendNext:@"2"];
[s3 sendNext:@"@"];
[s1 sendNext:@"c"];
[s2 sendNext:@"3"];
[s3 sendNext:@"#"];
/*打印输出结果,三个信号都发送一次sendNext之后才会收到第一次聚合信号
a,1,!
b,1,!
b,2,!
b,2,@
c,2,@
c,3,@
c,3,#
*/
//merge
RACSubject *s1 = [RACSubject subject];
RACSubject *s2 = [RACSubject subject];
RACSubject *s3 = [RACSubject subject];
//合并三个信号
RACSignal *mergeSg = [RACSignal merge:@[s1,s2,s3]];
[mergeSg subscribeNext:^(id _Nullable x) {
//收到九次信号，每次打印当前信号最新值
NSLog(@"%@",x);
}];
[s1 sendNext:@"a"];
[s2 sendNext:@"1"];
[s3 sendNext:@"!"];
[s1 sendNext:@"b"];
[s2 sendNext:@"2"];
[s3 sendNext:@"@"];
[s1 sendNext:@"c"];
[s2 sendNext:@"3"];
[s3 sendNext:@"#"];
//zip
RACSubject *s1 = [RACSubject subject];
RACSubject *s2 = [RACSubject subject];
RACSubject *s3 = [RACSubject subject];
RACSignal *zipSg = [RACSignal zip:@[s1,s2,s3]];
[zipSg subscribeNext:^(id _Nullable x) {
/*收到两次信号
( a, 1, !, ) (b, 3, @, )
*/
NSLog(@"%@",x);
}];
[s1 sendNext:@"a"];
[s2 sendNext:@"1"];
[s3 sendNext:@"!"];
[s1 sendNext:@"b"];
// [s2 sendNext:@"2"];
[s3 sendNext:@"@"];
[s1 sendNext:@"c"];
[s2 sendNext:@"3"];
[s3 sendNext:@"#"];
-
信号连接：
concat,then
-
concat:信号连接起来，按顺序响应信号。 -
then:只收到then返回的信号，之前的信号会被忽略
//concat
RACSignal *s1 = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber> _Nonnull subscriber) {
[subscriber sendNext:@"信号1"];
[subscriber sendCompleted];
return nil;
}];
RACSignal *s2 = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber> _Nonnull subscriber) {
[subscriber sendNext:@"信号2"];
[subscriber sendCompleted];
return nil;
}];
RACSignal *contactSg = [s1 concat:s2];
[contactSg subscribeNext:^(id _Nullable x) {
NSLog(@"%@", x);//依次打印 信号1 信号2
}];
//then
RACSignal *s1 = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber> _Nonnull subscriber) {
[subscriber sendNext:@"信号1"];
[subscriber sendCompleted];
return nil;
}];
RACSignal *s2 = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber> _Nonnull subscriber) {
[subscriber sendNext:@"信号2"];
[subscriber sendCompleted];
return nil;
}];
[[s2 then:^RACSignal * _Nonnull{
return s1;
}] subscribeNext:^(id _Nullable x) {
NSLog(@"%@", x);//只收到信号1，第一个信号会被忽略
}];
-
信号操作时间：
timeout,interval,dely
-
timeout:超时信号，超过设定时间后会收到错误信号 -
dely:延时发送信号
//设置signal的超时时间是2秒
RACSignal *signal = [[RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
//延时三秒发送信号
[[RACScheduler mainThreadScheduler] afterDelay:3 schedule:^{
[subscriber sendNext:@"delay"];
[subscriber sendCompleted];
}];
return nil;
}] timeout:2 onScheduler:[RACScheduler mainThreadScheduler]];
[signal subscribeNext:^(id x) {
NSLog(@"%@", x);
} error:^(NSError *error) {
NSLog(@"%@", error);//2秒后打印信息，因为发送信号延时了3秒
}];
- 还有其他的，持续更新。
RAC信号响应流程
- 信号声命周期：
创建信号-订阅信号-发送信号-销毁信号 -
信号响应流程分析
