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 的执行循序如下图

RACSignal_Flowchart.png

即创建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];
}];

}

如下图