self.usernameTextField.rac_textSignal 输入框文本变化信号
[[[self.usernameTextField.rac_textSignal
map:^id(NSString *text) {//map改变了事件传递的数据
return @(text.length);
}] filter:^BOOL(NSNumber *length) {//信号通过条件
return [length integerValue] > 3;
}] subscribeNext:^(id x) {
NSLog(@"%@", x); }];
RAC宏允许直接把信号的输出应用到对象的属性上。RAC宏有两个参数,第一个是需要设置属性值的对象,第二个是属性名。每次信号产生一个next事件,传递过来的值都会应用到该属性上,如下:
RAC(self.passwordTextField, backgroundColor) =[validPasswordSignal map:^id(NSNumber *passwordValid) {
return [passwordValid boolValue] ? [UIColor clearColor] : [UIColor yellowColor]; }];
聚合信号;RACSignal *signUpActiveSignal = [RACSignal combineLatest:@[validUsernameSignal, validPasswordSignal] reduce:^id(NSNumber *usernameValid, NSNumber *passwordValid) { return @([usernameValid boolValue] && [passwordValid boolValue]);}];
用于监听某个事件:[[self.signInButton rac_signalForControlEvents:UIControlEventTouchUpInside] subscribeNext:^(id x) {
NSLog(@"button clicked"); }];
RACObserve(self, name):监听某个对象的某个属性,返回的是信号。
[RACObserve(self.view, center) subscribeNext:^(id x) {
NSLog(@"%@",x);
}];
// 把监听到的通知转换信号
[[[NSNotificationCenter defaultCenter] rac_addObserverForName:UIKeyboardWillShowNotification object:nil] subscribeNext:^(id x) {
NSLog(@"键盘弹出");
];
创建信号:
-(RACSignal *)signInSignal {
return [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
[self.signInService signInWithUsername:self.usernameTextField.text password:self.passwordTextField.text complete:^(BOOL success) {
[subscriber sendNext:@(success)];
[subscriber sendCompleted];
}];
return nil; }];}
[[[self.signInButton rac_signalForControlEvents:UIControlEventTouchUpInside]
doNext:^(id x) {//附加操作,并不改变事件本身
self.signInButton.enabled = NO;
self.signInFailureText.hidden = YES;
}] flattenMap:^id(id x) {//把按钮点击事件转换为登录信号,同时还从内部信号发送事件到外部信号
return [self signInSignal];
}] subscribeNext:^(id x) {
NSLog(@"Sign in result: %@", x);
}];
1: RACSiganl(信号类)只是表示当数据改变时,信号内部会发出数据,它本身不具备发送信号的能力,而是交给内部一个订阅者subscriber去发出。2:默认一个信号都是冷信号,就算是值改变了,但你没有订阅这个信号的话它也不会触发的,只有订阅了这个信号,这个信号才会变为热信号,值改变了才会触发
RACSubject(信号提供者)它自己可以充当信号,又能发送信号(用来代替代理)
RACSequence RAC中的集合类,可用来快速遍历数组,字典!RACTuple RAC中的元组类,类似NSArray,用来包装值。
RACSequence的简单使用:
// 遍历字典,遍历出来的键值对会包装成RACTuple(元组对象
NSDictionary *dict = @{@"name":@"张旭",@"age":@24};
[dict.rac_sequence.signal subscribeNext:^(RACTuple *x) {
// RACTuple 就是一个元组,元组的概念在Swift有专门的介绍,没掌握的可以自己上网查一下!
NSLog(@"RACTuple = %@",x);
// 解包元组,会把元组的值,按顺序给参数里面的变量赋值
RACTupleUnpack(NSString *key,NSString *value) = x;
NSLog(@"%@ %@",key,value);
}];
字典转模型RAC高级写法:
NSString *filePath = [[NSBundle mainBundle] pathForResource:@"flags.plist" ofType:nil];
NSArray *dictArr = [NSArray arrayWithContentsOfFile:filePath];
// map:映射的意思,目的:把原始值value映射成一个新值
// array: 把集合转换成数组
// 底层实现:当信号被订阅,会遍历集合中的原始值,映射成新值,并且保存到新的数组里。
NSArray *flags = [[dictArr.rac_sequence map:^id(id value) {
return [FlagItem flagWithDict:value];
}] array];
RACCommand:
RAC中用于处理事件的类,可以把事件如何处理,事件中的数据如何传递,包装到这个类中,他可以很方便的监控事件的执行过程。
使用场景:监听按钮点击,网络请求
// 1.创建命令
RACCommand *command = [[RACCommand alloc] initWithSignalBlock:^RACSignal *(id input) {
NSLog(@"执行命令");
// 创建空信号,必须返回信号
// return [RACSignal empty];
// 2.创建信号,用来传递数据
return [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
[subscriber sendNext:@"请求数据"];
// 注意:数据传递完,最好调用sendCompleted,这时命令才执行完毕。
[subscriber sendCompleted];
return nil;
}];
}];
// 强引用命令,不要被销毁,否则接收不到数据
_conmmand = command;
// 3.订阅RACCommand中的信号
[command.executionSignals subscribeNext:^(id x) {
[x subscribeNext:^(id x) {
NSLog(@"%@",x);
}];
}];
// RAC高级用法
// switchToLatest:用于signal of signals,获取signal of signals发出的最新信号,也就是可以直接拿到RACCommand中的信号
[command.executionSignals.switchToLatest subscribeNext:^(id x) {
NSLog(@"%@",x);
}];
// 4.监听命令是否执行完毕,默认会来一次,可以直接跳过,skip表示跳过第一次信号,take表示接收2次信号
[[[command.executing skip:1] take:2] subscribeNext:^(id x) {
if ([x boolValue] == YES) {
// 正在执行
NSLog(@"正在执行");
}else{ // 执行完成
NSLog(@"执行完成");
}
}];
// 5.执行命令
[self.conmmand execute:@1];
RACMulticastConnection:用于当一个信号,被多次订阅时,为了保证创建信号时,避免多次调用创建信号中的block,造成副作用,可以使用这个类处理。
// RACMulticastConnection:解决重复请求问题
// 1.创建信号
RACSignal *signal = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
NSLog(@"发送请求");
[subscriber sendNext:@1];
return nil; }];
// 2.创建连接
RACMulticastConnection *connect = [signal publish];
// 3.订阅信号,
// 注意:订阅信号,也不能激活信号,只是保存订阅者到数组,必须通过连接,当调用连接,就会一次性调用所有订阅者的sendNext:
[connect.signal subscribeNext:^(id x) {
NSLog(@"订阅者一信号");
}];
[connect.signal subscribeNext:^(id x) {
NSLog(@"订阅者二信号");
}];
// 4.连接,激活信号
[connect connect];
rac_liftSelector:withSignalsFromArray:Signals:处理多个请求,都返回结果的时候,统一做处理.
RACSignal *request1 = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
// 发送请求1
[subscriber sendNext:@"发送请求1"];
return nil;
}];
RACSignal *request2 = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
// 发送请求2
[subscriber sendNext:@"发送请求2"];
return nil;
}];
// 使用注意:几个信号,参数一的方法就几个参数,每个参数对应信号发出的数据。
[self rac_liftSelector:@selector(updateUIWithR1:r2:) withSignalsFromArray:@[request1,request2]];
- (RACSignal *)then:(RACSignal * (^)(void))block; 这个方法功能是忽略接收者所有的next,直到信号complete返回一个新的RACSignal,当[self rac_signalForSelector:@selector(dismiss:)]信号sendComplete的时候,执行一个block,这个block必须返回一个不为空的新的RACSignal
[[self rac_signalForSelector:@selector(dismiss:)] then:^RACSignal *{
@strongify(self);
return [RACSignal return:self.array];
}];
或者:[[self rac_signalForSelector:@selector(dismiss:)] map:^id(id value) {
@strongify(self);
return self.array;
}];
对于需要监听协议方法的时候可以使用 - (RACSignal *)rac_signalForSelector:(SEL)selector fromProtocol:(Protocol *)protocol