map
[[self.textField.rac_textSignal flattenMap:^__kindof RACSignal * _Nullable(NSString * _Nullable value) {
NSLog(@"%@",value);
//不单纯的把文字内容返回,而是在一定的函数基础上返回
return [RACReturnSignal return:[NSString stringWithFormat:@"010-%@",value]];
}] subscribeNext:^(id _Nullable x) {
NSLog(@"subscribeNext %@",x);
}];
filter 过滤
[[self.textField.rac_textSignal filter:^BOOL(NSString * _Nullable value) {
//做过滤条件
@strongify(self)
if (self.textField.text.length > 6) {
self.textField.text = [self.textField.text substringToIndex:6];
}
return value.length < 6;
}] subscribeNext:^(NSString * _Nullable x) {
//逻辑区域
NSLog(@"subscribeNext %@",x);
}];
combine
@weakify(self)
RACSignal *signalA = self.textField.rac_textSignal;
RACSignal *singalB = self.passwordField.rac_textSignal;
[[RACSignal combineLatest:@[signalA,singalB] reduce:^id(NSString *account,NSString *password){
return @(account.length > 0 && password.length > 0);
}] subscribeNext:^(NSNumber *x) {
@strongify(self)
NSLog(@"subscribeNext %@",x);
self.button.enabled = x.integerValue;
}];
takeUntil
//takeUntil subjectA可以正常发送信号直到subjectB发送信号或者subjectB发送sendCompleted,就不能接受信号的内容了
RACSubject *subjectA = [RACSubject subject];
RACSubject *subjectB = [RACSubject subject];
[[subjectA takeUntil:subjectB] subscribeNext:^(id _Nullable x) {
NSLog(@"%@",x);
}];
[subjectA sendNext:@"A"];
[subjectA sendNext:@"B"];
// [subjectB sendNext:@"C"];
[subjectB sendCompleted];
[subjectA sendNext:@"D"];//不打印
retry
// retry重试 ：只要失败，就会重新执行创建信号中的block,直到成功.
__block int i = 0;
[[[RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
if (i == 10) {
[subscriber sendNext:@1];
}else{
NSLog(@"接收到错误");
[subscriber sendError:nil];
}
i++;
return nil;
}] retry] subscribeNext:^(id x) {
NSLog(@"%@",x);
} error:^(NSError *error) {
}];
replay
// `replay`重放：当一个信号被多次订阅,反复播放内容
RACSignal *signal = [[RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
[subscriber sendNext:@1];
[subscriber sendNext:@2];
return nil;
}] replay];
[signal subscribeNext:^(id x) {
NSLog(@"第一个订阅者%@",x);
}];
[signal subscribeNext:^(id x) {
NSLog(@"第二个订阅者%@",x);
}];
[signal subscribeNext:^(id x) {
NSLog(@"第三个订阅者%@",x);
}];
2019-01-31 17:29:57.448724+0800 RAC-OC_01[15855:609229] 第一个订阅者2
2019-01-31 17:29:57.448857+0800 RAC-OC_01[15855:609229] 第二个订阅者1
2019-01-31 17:29:57.448937+0800 RAC-OC_01[15855:609229] 第二个订阅者2
2019-01-31 17:29:57.449038+0800 RAC-OC_01[15855:609229] 第三个订阅者1
2019-01-31 17:29:57.449115+0800 RAC-OC_01[15855:609229] 第三个订阅者2
timeOut
RACSignal *signal = [[RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
return nil;
}] timeout:1 onScheduler:[RACScheduler currentScheduler]];
[signal subscribeNext:^(id _Nullable x) {
NSLog(@"%@",x);
} error:^(NSError * _Nullable error) {
NSLog(@"%@",error);
}];
switchToLatest
RACSubject *signalOfSignals = [RACSubject subject];
RACSubject *signal = [RACSubject subject];
//获取信号中的号最近发出的信号,订阅最近发出的信号
//注意siwtchToLatest:只能用于信号中的信号
[[signalOfSignals switchToLatest] subscribeNext:^(id _Nullable x) {
NSLog(@"%@",x);
}];
[signalOfSignals sendNext:signal];
[signal sendNext:@"1"];
[signal sendNext:@"2"];
[signal sendCompleted];
[signal sendNext:@"3"];
2019-01-31 17:30:53.760808+0800 RAC-OC_01[15885:611621] 1
2019-01-31 17:30:53.760955+0800 RAC-OC_01[15885:611621] 2
take和takeLast
//takeLast 和take的用法基本一样,但是是取最后的设定的那几个在值,如下去的是最后发送的两个值:2,3
//注意:takeLast 一定要用sendCompleted,告诉他发送完成了,这样才能取到最后的几个值
RACSubject *subject = [RACSubject subject];
[[subject takeLast:2] subscribeNext:^(id _Nullable x) {
NSLog(@"takeLast%@",x);
}];
[[subject take:1] subscribeNext:^(id _Nullable x) {
NSLog(@"take %@",x);
}];
[subject sendNext:@"1"];
[subject sendNext:@"2"];
[subject sendNext:@"3"];
[subject sendCompleted];
2019-01-31 17:31:39.809828+0800 RAC-OC_01[15913:613819] take 1
2019-01-31 17:31:39.810365+0800 RAC-OC_01[15913:613819] takeLast2
2019-01-31 17:31:39.810454+0800 RAC-OC_01[15913:613819] takeLast3
skip
// 表示输入第一次，不会被监听到，跳过第一次发出的信号
[[self.textField.rac_textSignal skip:1] subscribeNext:^(NSString * _Nullable x) {
NSLog(@"subscribeNext skip %@",x);
}];
[self.textField.rac_textSignal subscribeNext:^(NSString * _Nullable x) {
NSLog(@"subscribeNext %@",x);
}];
distinctUntilChanged
//distinctUntilChanged 当上一次的值和当前的值有明显的变化就会发出信号,否则会被忽略掉
//在开发中，刷新UI经常使用，只有两次数据不一样才需要刷新
RACSubject *subject = [RACSubject subject];
[[subject distinctUntilChanged] subscribeNext:^(id _Nullable x) {
NSLog(@"%@",x);
}];
[subject sendNext:@"1"];
[subject sendNext:@"1"];
[subject sendNext:@"2"];
[subject sendCompleted];
[[self.textField.rac_textSignal distinctUntilChanged] subscribeNext:^(NSString * _Nullable x) {
NSLog(@"textField change %@",x);
}];
2019-01-31 17:32:56.801033+0800 RAC-OC_01[15940:616672] 1
2019-01-31 17:32:56.801313+0800 RAC-OC_01[15940:616672] 2
2019-01-31 17:32:56.803264+0800 RAC-OC_01[15940:616672] textField change
ignore
// 内部调用filter过滤，忽略掉ignore的值
[[self.textField.rac_textSignal ignore:@"1"] subscribeNext:^(NSString * _Nullable x) {
NSLog(@"%@",x);
}];
reduce
//reduce`聚合:用于信号发出的内容是元组，把信号发出元组的值聚合成一个值
//其中Aggregation(聚合关系)、Composition(合成关系)属于Association(关联关系)，是特殊的Association关联关系。
//可以延伸组合关系,聚合关系
//组合关系 A-B组合成了C C包含所有的A和B
//聚合关系 聚合关系是整体和个体的关系(是强的关联关系) 公司与个人,但是个人不完全属于公司
// 聚合常见的用法，（先组合在聚合）:combineLatest:(id<NSFastEnumeration>)signals reduce:(id (^)())reduceBlock
// reduce中的block简介:
// reduceblcok中的参数，有多少信号组合，reduceblcok就有多少参数，每个参数就是之前信号发出的内容
// reduceblcok的返回值：聚合信号之后的内容。
RACSignal *signalA = self.textField.rac_textSignal;
RACSignal *signalB = [self.button rac_signalForControlEvents:UIControlEventTouchUpInside];
RACSignal *reduceSignal = [RACSignal combineLatest:@[signalA,signalB] reduce:^id (NSString *textFieldText,UIButton *value2 ){
return [NSString stringWithFormat:@"reduce == %@ %@",textFieldText,value2];
}];
[reduceSignal subscribeNext:^(id _Nullable x) {
NSLog(@"subscribeNext %@",x);
}];
zip
// 底层实现:
// 1.定义压缩信号，内部就会自动订阅signalA，signalB
// 2.每当signalA或者signalB发出信号，就会判断signalA，signalB有没有发出个信号，有就会把最近发出的信号都包装成元组发出。
RACSignal *signalA = self.textField.rac_textSignal;
RACSignal *signalB = [self.button rac_signalForControlEvents:UIControlEventTouchUpInside];
// 合并信号,任何一个信号发送数据，都能监听到.
RACSignal *zipSignal = [signalA zipWith:signalB];
[zipSignal subscribeNext:^(id _Nullable x) {
NSLog(@"%@",x);
}];
combineLatestWith
//将多个信号合并起来，并且拿到各个信号的最新的值,必须每个合并的signal至少都有过一次sendNext，才会触发合并的信号。
RACSignal *signalA = self.textField.rac_textSignal;
RACSignal *signalB = [self.button rac_signalForControlEvents:UIControlEventTouchUpInside];
// 合并信号,任何一个信号发送数据，都能监听到.
RACSignal *comSignal = [signalA combineLatestWith:signalB];
[comSignal subscribeNext:^(id x) {
NSLog(@"subscribeNext %@",x[0]);
}];
// 底层实现：
// 1.当组合信号被订阅，内部会自动订阅signalA，signalB,必须两个信号都发出内容，才会被触发。
// 2.并且把两个信号组合成元组发出。
区别于zipWith zipWith两个信号都要有记录,如果记录的信号触发过了 就不在触发
zipWith 记录每一次信号 combineLatestWith记录最后一次的信号
merge
// merge:把多个信号合并成一个信号
//创建多个信号
RACSignal *signalA = self.textField.rac_textSignal;
RACSignal *signalB = [self.button rac_signalForControlEvents:UIControlEventTouchUpInside];
RACSignal *mergeSignalA = [signalA merge:signalB];
// 合并信号,任何一个信号发送数据，都能监听到
[mergeSignalA subscribeNext:^(id _Nullable x) {
NSLog(@"mergeSignalA %@",x);//此处只打印一个信号而不是所所有的merge的信号都打印出来
}];
then
[[[RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber> _Nonnull subscriber) {
[subscriber sendNext:@"1"];
[subscriber sendNext:@"2"];
[subscriber sendCompleted];
return nil;
}] then:^RACSignal * _Nonnull{
return [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber> _Nonnull subscriber) {
[subscriber sendNext:@"3"];
[subscriber sendCompleted];
return nil;
}];
}] subscribeNext:^(id _Nullable x) {
NSLog(@"%@",x);
}];
2019-01-31 17:37:47.485780+0800 RAC-OC_01[16000:626331] 3
concat
RACSignal *signalA = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber> _Nonnull subscriber) {
[subscriber sendNext:@"1"];
[subscriber sendCompleted];
return nil;
}];
RACSignal *signalB = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber> _Nonnull subscriber) {
[subscriber sendNext:@"2"];
[subscriber sendCompleted];
return nil;
}];
RACSignal *contactSignal = [signalA concat:signalB];
[contactSignal subscribeNext:^(id _Nullable x) {
NSLog(@"%@",x);
}];
2019-01-31 17:38:27.049441+0800 RAC-OC_01[16021:627873] 1
2019-01-31 17:38:27.049640+0800 RAC-OC_01[16021:627873] 2
RACDisposable
// 创建信号
RACSignal *signal = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber> _Nonnull subscriber) {
// block调用时刻：每当有订阅者订阅信号，就会调用block。
[subscriber sendNext:@"1"];
[subscriber sendNext:@"2"];
// 如果不在发送数据，最好发送信号完成，内部会自动调用[RACDisposable disposable]取消订阅信号。
// [subscriber sendCompleted];
NSLog(@"subscriber == %@",subscriber);
[subscriber sendError:[NSError errorWithDomain:NSURLErrorDomain code:404 userInfo:nil]];
RACDisposable *disposable = [RACDisposable disposableWithBlock:^{
// 销毁信号
// block调用时刻：当信号发送完成或者发送错误，就会自动执行这个block,取消订阅信号。
// 执行完Block后，当前信号就不在被订阅了。
NSLog(@"开始销毁");
}];
return disposable;
}];
//订阅信号,才会激活信号.
[signal subscribeNext:^(id _Nullable x) {
NSLog(@"x == %@",x);
}];
[signal subscribeError:^(NSError * _Nullable error) {
NSLog(@"error x == %@",error);
}];
2019-01-31 17:39:33.777755+0800 RAC-OC_01[16053:630494] x == 1
2019-01-31 17:39:33.777906+0800 RAC-OC_01[16053:630494] x == 2
2019-01-31 17:39:33.778023+0800 RAC-OC_01[16053:630494] subscriber == <RACPassthroughSubscriber: 0x6000013d5240>
2019-01-31 17:39:33.778160+0800 RAC-OC_01[16053:630494] 开始销毁
2019-01-31 17:39:33.778382+0800 RAC-OC_01[16053:630494] subscriber == <RACPassthroughSubscriber: 0x600001387bc0>
2019-01-31 17:39:33.778538+0800 RAC-OC_01[16053:630494] error x == Error Domain=NSURLErrorDomain Code=404 "(null)"
2019-01-31 17:39:33.778648+0800 RAC-OC_01[16053:630494] 开始销毁
关于开始销毁打印两次问题在下篇文章会解释
网友评论