iOS RAC 基本使用

作者: 一滴矿泉水 | 来源:发表于2022-06-09 15:43 被阅读0次

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:@"NotificationName" object:nil] subscribeNext:^(NSNotification * _Nullable x) {
    //处理接收到的通知
    NSLog(@"%@",x);
}];
//发送通知
[[NSNotificationCenter defaultCenter] postNotificationName:@"NotificationName" object:@"999" userInfo:@{@"key":@"6666"}];

RAC和代理

self.textField = [[UITextField alloc] initWithFrame:CGRectMake(100, 100, 200, 50)];
self.textField.placeholder = @"RAC_Test";
self.textField.delegate = self;
[self.view addSubview:_textField];
// 添加UITextFieldDelegate代理方法textFieldDidBeginEditing:信号
[[self rac_signalForSelector:@selector(textFieldDidBeginEditing:) fromProtocol:@protocol(UITextFieldDelegate)] subscribeNext:^(RACTuple * _Nullable x) {
    //RACTuple：元组类型
    UITextField *field  = [x first];
    //[field resignFirstResponder];
    NSLog(@"---%@",field.text);
}];

rac_signalForSelector:fromProtocol:添加代理方法信号。

值得注意的是，接收订阅信号的参数是RACTuple元组类型，熟悉swift语法的话对元组类型一定不陌生，元组是把多个值组合成一个复合值。元组内的值可以是任意类型，并不要求是相同类型

UIButton

// rac_signalForControlEvents：用于监听某个事件。
// 把按钮点击事件转换为信号，点击按钮，就会发送信号
UIButton *button =[[UIButton alloc] initWithFrame:CGRectMake(300, 300, 50, 50)];
[self.view addSubview:button];
button.backgroundColor = [UIColor orangeColor];
//按钮点击信号需要 防止循环引用
@weakify(self);//防止循环引用的问题
[[button rac_signalForControlEvents:UIControlEventTouchUpInside] subscribeNext:^(id x) {
    @strongify(self);//暂时强引用
    NSLog(@"按钮被点击了");
}];

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(手势)

//给Lable或者View添加监听
UILabel *textLab = [[UILabel alloc] initWithFrame:CGRectMake(100, 100, 200, 30)];
textLab.backgroundColor = [UIColor greenColor];
textLab.text = @"********************";
textLab.userInteractionEnabled = YES;
[self.view addSubview:textLab];
//手势
UITapGestureRecognizer *tap = [[UITapGestureRecognizer alloc] init];
[textLab addGestureRecognizer:tap];
[[tap rac_gestureSignal] subscribeNext:^(id x) {
    NSLog(@"点击Lab");
}];

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和flattenMap,把原有信号中的值映射成新的值。
map:方法返回依旧是一个信号RACSignal类型，如下代码，将rac_textSignal信号中的字符串经过map映射处理成字符串的长度。注意：map的block中必须要返回对象类型的数据。

// 修改数据类型格式 ，转换为自己想要的数据 然后返回
[[self.textField.rac_textSignal map:^id _Nullable(NSString * _Nullable value) {
    // 对原数据进行处理
    // 可在这里面对输入框内容进行转换 ，返回自己想要类型的数据
    return @(value.length);
}] subscribeNext:^(id _Nullable x) {
    // 处理后的新值
    NSLog(@"映射后的新值：%@",x);//输出字符串长度
}];

flattenMap:把源信号的内容映射成一个新的信号，信号可以是任意类型。

[[self.textField.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.textField.rac_textSignal filter:^BOOL(NSString * _Nullable value) {
    //输入字符串长度大于3
    return value.length > 3;
}] subscribeNext:^(id _Nullable x) {
    //获取到输入字符串长度大于3的信号
    //当输入字符串长度大于3才会在这里打印
    NSLog(@"%@",x);
}];

// ignore
[[self.textField.rac_textSignal ignore:@"n"] subscribeNext:^(NSString * _Nullable x) {
    NSLog(@"这里收不到信号 %@",x);//输入n，这里收不到信号
    
}];

// distinctUntilChanged
RACSubject *subject = [RACSubject subject];
[[subject distinctUntilChanged] subscribeNext:^(id x) {
    //收到的信号依次是a b c,第三次发送的b被忽略了
    NSLog(@"第三次发送的b被忽略了 sendNext -- %@", x);
}];
// 发送信号
[subject sendNext:@"a"];
[subject sendNext:@"b"];
[subject sendNext:@"b"];
[subject sendNext:@"c"];

信号合并：`combineLatest`,`reduce`,`merge`,`zip`

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秒
}];

参考链接：https://www.jianshu.com/p/58a1214fc6d8（文章介绍详细基本是完全Copy）

文章持续更新中、希望对各位有所帮助、有问题可留言大家共同学习.

iOS RAC 基本使用

一、RAC的基本使用

RAC和KVO

RAC和通知

RAC和代理

UIButton

UITextField

UITapGestureRecognizer(手势)

序列 `sequence`

二、RAC中的高阶函数

信号映射：`map`和`flattenMap`

信号过滤：`filter`,`ignore`,`distinctUntilChanged`

信号合并：`combineLatest`,`reduce`,`merge`,`zip`

信号连接：`concat`,`then`

信号操作时间：`timeout`,`interval`,`dely`

相关文章

网友评论

延伸阅读

深度阅读

栏目导航

热点阅读

iOS RAC 基本使用

一、RAC的基本使用

RAC和KVO

RAC和通知

RAC和代理

UIButton

UITextField

UITapGestureRecognizer(手势)

序列 sequence

二、RAC中的高阶函数

信号映射：map和flattenMap

信号过滤：filter,ignore,distinctUntilChanged

信号合并：combineLatest,reduce,merge,zip

信号连接：concat,then

信号操作时间：timeout,interval,dely

相关文章

网友评论

延伸阅读

深度阅读

栏目导航

热点阅读

序列 `sequence`

信号映射：`map`和`flattenMap`

信号过滤：`filter`,`ignore`,`distinctUntilChanged`

信号合并：`combineLatest`,`reduce`,`merge`,`zip`

信号连接：`concat`,`then`

信号操作时间：`timeout`,`interval`,`dely`