RACSignal类
他的基类是RACStream,一般表示将来有数据传递,只要有数据改变,信号内部接收到数据,就会马上发出数据。
信号类(RACSiganl),只是表示当数据改变时,信号内部会发出数据,它本身不具备发送信号的能力,而是交给内部一个订阅者去发出。
默认一个信号都是冷信号,也就是值改变了,也不会触发,只有订阅了这个信号,这个信号才会变为热信号,值改变了才会触发。
如何订阅信号:调用信号RACSignal的subscribeNext就能订阅
具体执行流程
使用三部曲,
1.创建信号
2.订阅信号
3.发送信息
- 创建和发送
-(void)CreateSignal
{
//三步 创建 订阅 发送
self.signal = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber> _Nonnull subscriber) {
//这个block什么时候调用呢?,在我们订阅信号的时候调用
NSLog(@"创建signal-----");
//发送信息
[subscriber sendNext:@"这是一个实验"];
// 如果不在发送数据,最好发送信号完成,内部会自动调用[RACDisposable disposable]取消订阅信号。
[subscriber sendCompleted];
NSLog(@"什么时间运行");
return [RACDisposable disposableWithBlock:^{
// block调用时刻:当信号发送完成或者发送错误,就会自动执行这个block,取消订阅信号。
// 执行完 Block后,当前信号就不在被订阅了。
NSLog(@"信号被销毁");
}];
}];
}
RACDisposable:用于取消订阅或者清理资源,当信号发送完成或者发送错误的时候,就会自动触发它。比如:不想监听某个信号时,可以通过它主动取消订阅信号
RACSubject:RACSubject:信号提供者,自己可以充当信号,又能发送信号。通常用来代替代理,有了它,就不必要定义代理了。
- 订阅
#
pragma mark ---- 订阅信号
- (IBAction)Subscription:(id)sender {
//方法一
// [self.signal subscribeNext:^(id _Nullable x) {
//
// NSLog(@"订阅信号-----%@",x);
// }];
//方法二
[self.signal subscribeNext:^(id _Nullable x) {
//接收到正常发送的信号,并打印信号传过来的信息
NSLog(@"订阅信号-----%@",x);
} error:^(NSError * _Nullable error) {
//接收到错误的信号,并打印出错误信息
NSLog(@"%@",error);
} completed:^{
//接收到完成信号, 并打印出完成信息,若为错误信号则不打印
NSLog(@"完成");
}];
}
运行结果:
2018-03-26 12:31:32.054986+0800 RACSignal[92861:4461509] 创建signal-----
2018-03-26 12:31:32.055229+0800 RACSignal[92861:4461509] 发送的信息是-----这是一个实验
2018-03-26 12:31:32.055507+0800 RACSignal[92861:4461509] 完成
2018-03-26 12:31:32.055722+0800 RACSignal[92861:4461509] 什么时间运行
RACSubscriber:表示订阅者的意思,用于发送信号,这是一个协议,不是一个类,只要遵守这个协议,并且实现方法才能成为订阅者。通过create创建的信号,都有一个订阅者,帮助他发送数据。
-
从上面的demo 中可以看出Signal 的执行循序如下图
即创建signal的 block 在订阅之后 调用,订阅的block 在发送完数据之后调用
循环引用的问题
RAC在使用的时候由于系统提供的信号是始终存在的,所以在block中使用属性或者成员变量几乎都会涉及到一个循环引用的问题,有两种方法可以解决,使用weakself解决或者RAC提供的weak-strong dance.用法也比较简单:在 block 的外部使用 @weakify(self),在 block 的内部使用 @strongify(self),具体的方法如下:
#pragma mark ---- 如何解决循环引用
-(void)RetainCiteBtn
{
//@-----解决循环引用------
@weakify(self);
[[self.RetainCite rac_signalForControlEvents:UIControlEventTouchUpInside]
subscribeNext:^(__kindof UIControl * _Nullable x) {
@strongify(self);
NSLog(@"解决循环引用问题%@",self.view);
}];
}
简单应用
1,实现对 textField输入内容的实时监听
@property (weak, nonatomic) IBOutlet UITextField *name_TF;
#pragma mark ---- textField输入内容的实时监听
-(void)name_tfSignal
{
[[self.name_TF rac_textSignal] subscribeNext:^(NSString * _Nullable x) {
NSLog(@"%@",x);
}];
}
监听文本框文字改变:rac_textSignal:只要文本框发出改变就会发出这个信号
2.想将两个信号或者多个整合成一个信号
-(void)nameWithpwSignal{
[[RACSignal combineLatest:@[self.name_TF.rac_textSignal,self.pw_TF.rac_textSignal]]
subscribeNext:^(RACTuple * _Nullable x)
{
NSString * name = x.first; NSString * pwd = x.second;
NSLog(@"name:%@,age:%@",name,pwd);
}];
}
关于合并信号的几个方法,combineLatest: zip Sample, 在后续的 demo 中会有体现
3.判断登录按钮是否能点击
-(void)isEventforLogin
{
//根据texfile的内容觉得按钮是否可以点击
@weakify(self);
[[RACSignal combineLatest:@[self.name_TF.rac_textSignal,self.pw_TF.rac_textSignal]
reduce:^id(NSString * name , NSString * pw){
return @(name.length>0&&pw.length>0);
}]subscribeNext:^(id _Nullable x) {
@strongify(self);
self.Login.enabled = [x boolValue];
}];
}
4.UI绑定 输入框输入实施改变model 的值, model值改变通知label显示改动后的信息
-(void)UIChangAndModel
{
self.model = [[RACSignalModel alloc]init];
//UI绑定模型
self.model.name = @"初始化";
// self.model.age = 0;
//双向绑定
//RACChannelTo(self.ChageValue, text) =RACChannelTo(self.model, name); 等同下句话
RAC(self.ChageValue,text) = RACObserve(self.model, name);
/*
RAC(self.ChageAge,text) = RACObserve(model, age);
这句话程序崩溃,信息 reason: '-[__NSCFNumber rangeOfCharacterFromSet:]: unrecognized selector sent to instance 0xb000000000000003'原因如下
这里不能使用基本数据类型,RAC中传递的都是id类型,使用基本类型会崩溃,所以使用map方法对返回值进行了更替如下:
*/
RAC(self.ChangeAgeLabel,text)= [RACObserve(self.model, age) map:^id(id value) {
return [value description];
}];
[[RACSignal combineLatest:@[self.ChangModel.rac_textSignal,self.ChageAge.rac_textSignal]] subscribeNext:^(RACTuple * x) {
self.model.name = x.first;
self.model.age = [x.second intValue];
}];
}
如下图
demo 整理完会一并上传;
-
附上关于 RACSignal的思维导图方便大家理解(还未完成)