阅读 46

RAC相关操作

[TOC]


RACSequence遍历数组

NSArray *array = @[@"1",@"2",@"3",@"4",@"5"];
	[array.rac_sequence.signal  subscribeNext:^(id x) {
		NSLog(@"%@",x);
	}];
输出
2018-01-09 15:13:46.177025+0800 PodTest[26525:4865191] 1
2018-01-09 15:13:46.177204+0800 PodTest[26525:4865191] 2
2018-01-09 15:13:46.177336+0800 PodTest[26525:4865191] 3
2018-01-09 15:13:46.177470+0800 PodTest[26525:4865191] 4
2018-01-09 15:13:46.177592+0800 PodTest[26525:4865191] 5
复制代码

RACSequence遍历字典

//遍历出来的键值对包装成了RACTuple(元组对象)
NSDictionary *dic = @{@"1" : @"one",@"2" : @"two",@"3" : @"three"};
[dic.rac_sequence.signal subscribeNext:^(id x) {
	// 解包元组,会把元组的值,按顺序给参数里面的变量赋值
	RACTupleUnpack(NSString *key, NSString *value) = x;
	NSLog(@"key = %@; value = %@", key, value);
}];
输出
2018-01-09 15:34:00.706901+0800 PodTest[26836:4880078] key = 1; value = one
2018-01-09 15:34:00.707161+0800 PodTest[26836:4880078] key = 2; value = two
2018-01-09 15:34:00.707309+0800 PodTest[26836:4880078] key = 3; value = three
复制代码

flattenMap,Map

作用:用于把源信号内容映射成新的内容。

flattenMap
  • 作用:把源信号的内容映射成一个新的信号,信号可以是任意类型。
  • 传入一个blockblock类型是返回值RACStream,参数value
  • 参数value就是源信号的内容,拿到源信号的内容做处理
  • 包装成RACReturnSignal信号,返回出去。返回的必须是一个信号。
[[self.textField.rac_textSignal flattenMap:^RACStream *(id value) {
		return [RACReturnSignal return:[NSString stringWithFormat:@"输出:%@",value]];
	}] subscribeNext:^(id x) {

	}];
复制代码
Map
  • 作用:把源信号的值映射成一个新的值
  • 传入一个block,类型是返回对象,参数是value
  • value就是源信号的内容,直接拿到源信号的内容做处理
  • 把处理好的内容,直接返回就好了,不用包装成信号,返回的值,就是映射的值。
[[self.textField.rac_textSignal map:^id(NSString * value) {
		return @(value.length);
	}] subscribeNext:^(id x) {
		NSLog(@"---%@",x);
	}];
复制代码
FlatternMap和Map的区别
  • FlatternMap中的Block返回信号。
  • Map中的Block返回对象
  • 开发中,如果信号发出的值不是信号,映射一般使用Map
  • 开发中,如果信号发出的值是信号,映射一般使用FlatternMap.
RACSubject *signals = [RACSubject subject];
	RACSubject *signal = [RACSubject subject];
	[[signals flattenMap:^RACStream *(id value) {
      //value不是信号 会崩溃
		return value;
	}] subscribeNext:^(id x) {
		NSLog(@"%@",x);
	}];
	[signals sendNext:signal];
	[signal sendNext:@"1221"];
复制代码

concat:组合

  • 作用:按一定顺序拼接信号,当多个信号发出的时候,有顺序的接收信号。
RACSignal *signal = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
		[subscriber sendNext:@"123"];
		[subscriber sendCompleted];
		return nil;
	}];
	
	RACSignal *signal1 = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
		[subscriber sendNext:@"234"];
		return nil;
	}];
	[[signal concat:signal1] subscribeNext:^(id x) {
		NSLog(@"%@",x);
	}];
复制代码
  • signal1拼接到signal后,signal发送完成,signal1才会被激活。
  • 以后只需要面对拼接信号开发
  • 订阅拼接的信号,不需要单独订阅signalsignal1
  • 内部会自动订阅
  • 注意:第一个信号必须发送完成,第二个信号才会被激活
concat底层实现
  • 当拼接信号被订阅,就会调用拼接信号的didSubscribe
  • didSubscribe中,会先订阅第一个源信号signal
  • 会执行第一个源信号signaldidSubscribe
  • 第一个源信号signal didSubscribe中发送值,就会调用第一个源信号signal订阅者的nextBlock,通过拼接信号的订阅者把值发送出来.
  • 第一个源信号signaldidSubscribe中发送完成,就会调用第一个源信号signal订阅者的completedBlock,订阅第二个源信号signal1这时候才激活signal1
  • 订阅第二个源信号signal1,执行第二个源信号signal1的didSubscribe
  • 第二个源信号signal)didSubscribe中发送值,就会通过拼接信号的订阅者把值发送出来.

then

  • 作用:用于连接两个信号,当第一个信号完成,才会连接then返回的信号
  • 注意使用then,之前信号的值会被忽略掉.
  • 底层实现:1、先过滤掉之前的信号发出的值。2.使用concat连接then返回的信号
	RACSignal *signal = [RACSubject createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
		[subscriber sendNext:@"123"];
		[subscriber sendCompleted];
		return nil;
	}];
	[[signal then:^RACSignal *{
		return [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
			[subscriber sendNext:@"234"];
			return nil;
		}];
	}] subscribeNext:^(id x) {
		//输出 234
		NSLog(@"%@",x);
	}];
复制代码

merge

  • 把多个信号合并为一个信号,任何一个信号有新值的时候就会调用
RACSubject *signal = [RACSubject subject];
		RACSignal *signal1 = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
		[subscriber sendNext:@"234"];
		return nil;
	}];
	[[signal merge:signal1] subscribeNext:^(id x) {
		//--234
		//123
		NSLog(@"--%@",x);
	}];
	[signal sendNext:@"123"];
复制代码
底层实现
  • 合并信号被订阅的时候,就会遍历所有信号,并且发出这些信号
  • 每发出一个信号,这个信号就会被订阅
  • 也就是合并信号一被订阅,就会订阅里面所有的信号
  • 只要有一个信号被发出就会被监听

zipWith

  • 把两个信号压缩成一个信号,只有当两个信号同时发出信号内容时,并且把两个信号的内容合并成一个元组,才会触发压缩流的next事件
	RACSignal *signalA = [RACSignal createSignal:^RACDisposable *(id subscriber) {
		[subscriber sendNext:@123];
		return nil;
	}];
	RACSignal *signalB = [RACSignal createSignal:^RACDisposable *(id subscriber) {
		[subscriber sendNext:@234];
		return nil;
	}];
	RACSignal *zipSignal = [signalA zipWith:signalB];
	[zipSignal subscribeNext:^(id x) {
		NSLog(@"%@",x);
	}];
2018-01-10 11:50:35.499433+0800 PodTest[32655:5266997] <RACTuple: 0x608000004cc0> (
    123,
    234
)
复制代码
底层实现
  • 定义压缩信号,内部就会自动订阅signalAsignalB
  • 每当signalA或者signalB发出信号,就会判断signalA,signalB有没有发出个信号,有就会把最近发出的信号都包装成元组发出

combineLatest

  • 将多个信号合并起来,并且拿到各个信号的最新的值,必须每个合并的signal至少都有过一次sendNext,才会触发合并的信号
RACSubject *signal = [RACSubject subject];
RACSubject *signal1 = [RACSubject subject];
[[signal combineLatestWith:signal1] subscribeNext:^(id x) {
	NSLog(@"%@",x);
}];
[signal sendNext:@"123"];
[signal1 sendNext:@"123"];
2018-01-10 11:57:56.511590+0800 PodTest[32766:5275918] <RACTuple: 0x60800000c520> (
    123,
    123
)
复制代码
底层实现
  • 当组合信号被订阅,内部会自动订阅signalAsignalB,必须两个信号都发出内容,才会被触发
  • 并且把两个信号组合成元组发出

reduce

  • 聚合:用于信号发出的内容是元组,把信号发出元组的值聚合成一个值
常见用法
  • 先组合在聚 combineLatest:(id)signals reduce:(id (^)())reduceBlock
简介
  • reduceblcok中的参数,有多少信号组合,reduceblcok就有多少参数,每个参数就是之前信号发出的内容
  • reduceblcok的返回值:聚合信号之后的内容
底层实现
  • 订阅聚合信号,每次有内容发出,就会执行reduceblcok,把信号内容转换成reduceblcok返回的值
RACSignal *signalA = [RACSignal createSignal:^RACDisposable *(id subscriber) {
		[subscriber sendNext:@123];
		return nil;
	}];
	RACSignal *signalB = [RACSignal createSignal:^RACDisposable *(id subscriber) {
		[subscriber sendNext:@234];
		return nil;
	}];
	[[RACSignal combineLatest:@[signalA,signalB] reduce:^id(NSNumber *A,NSNumber *B){
		return [NSString stringWithFormat:@"%@%@",[A stringValue],[B stringValue]];
	}] subscribeNext:^(id x) {
      //2018-01-10 15:09:17.520342+0800 PodTest[33327:5393123] 123234
		NSLog(@"%@",x);
	}];
复制代码

filter

  • 过滤信号,使用它可以获取满足条件的信号
[[self.textField.rac_textSignal filter:^BOOL(NSString *value) {
		return value.length > 3;
	}] subscribeNext:^(id x) {
  //只能输出字符长度大于三的
		NSLog(@"%@",x);
	}];
复制代码

ignore

  • 忽略完某些值的信号
  • 内部调用filter过滤,忽略掉ignore的值
[[_textField.rac_textSignal ignore:@"1"] subscribeNext:^(id x) {

NSLog(@"%@",x);

}];
复制代码

take

  • 从开始一共取N次的信号
RACSubject *signal = [RACSubject subject];
[[signal take:1] subscribeNext:^(id x) {
  //只输出1
    NSLog(@"%@",x);
}];
[signal sendNext:@"1"];
[signal sendNext:@"2"];
复制代码

takeLast

  • 取最后N次的信号,前提条件,订阅者必须调用完成,因为只有完成,就知道总共有多少信号.
`RACSubject *signal = [RACSubject subject];
[[signal takeLast:1] subscribeNext:^(id x) {
  //只输出 2
    NSLog(@"%@",x);
}];
[signal sendNext:@"1"];
[signal sendNext:@"2"];
[signal sendCompleted];
复制代码

takeUntil

  • (RACSignal *):获取信号直到执行完这个信号
// 监听文本框的改变,直到当前对象被销毁
[_textField.rac_textSignal takeUntil:self.rac_willDeallocSignal];
复制代码

skip

  • (NSUInteger):跳过几个信号,不接受
// 表示输入第一次,不会被监听到,跳过第一次发出的信号
[[_textField.rac_textSignal skip:1] subscribeNext:^(id x) {
NSLog(@"%@",x);
}];
复制代码

switchToLatest

  • 用于signalOfSignals(信号的信号),有时候信号也会发出信号,会在signalOfSignals中,获取signalOfSignals发送的最新信号
RACSubject *signalOfSignals = [RACSubject subject];

RACSubject *signal = [RACSubject subject];

[signalOfSignals sendNext:signal];

[signal sendNext:@1];

// 获取信号中信号最近发出信号,订阅最近发出的信号。

// 注意switchToLatest:只能用于信号中的信号

[signalOfSignals.switchToLatest subscribeNext:^(id x) {

NSLog(@"%@",x);

}];
复制代码

doNext

	RACSignal *signal = [RACSignal createSignal:^RACDisposable *(id subscriber) {
		[subscriber sendNext:@234];
		[subscriber sendCompleted];
		return nil;
	}];
	[[[signal doNext:^(id x) {
		NSLog(@"--%@",x);
	}] doCompleted:^{
		NSLog(@"qqq");
	}] subscribeNext:^(id x) {
		NSLog(@"==%@",x);
	}];
2018-01-10 16:49:27.097852+0800 PodTest[34202:5494958] --234
2018-01-10 16:49:27.097955+0800 PodTest[34202:5494958] ==234
2018-01-10 16:49:27.098043+0800 PodTest[34202:5494958] qqq
复制代码

deliverOn

  • 内容传递切换到制定线程中,副作用在原来线程中,把在创建信号时block中的代码称之为副作用

subscribeOn

  • 内容传递和副作用都会切换到制定线程中

timeout

  • 超时,可以让一个信号在一定的时间后,自动报错
RACSignal *signal = [RACSignal createSignal:^RACDisposable *(id subscriber) {
      [subscriber sendNext:@234];
      [subscriber sendCompleted];
      return nil;
  }];
  [[[signal delay:3] timeout:2 onScheduler:[RACScheduler currentScheduler]] subscribeNext:^(id x) {
      NSLog(@"%@",x);
  } error:^(NSError *error) {
      NSLog(@"%@",error);
  }];
复制代码

interval

  • 定时:每隔一段时间发出信号
  • 相当于一个定时器
[[RACSignal interval:2 onScheduler:[RACScheduler currentScheduler]] subscribeNext:^(id x) {
    NSLog(@"%@",x);
} error:^(NSError *error) {
    NSLog(@"%@",error);
}];
复制代码

delay

  • 延迟发送next
RACSignal *signal = [[[RACSignal createSignal:^RACDisposable *(id subscriber) {

[subscriber sendNext:@1];

return nil;

}] delay:2] subscribeNext:^(id x) {

NSLog(@"%@",x);

}];
复制代码

retry

  • 重试 :只要失败,就会重新执行创建信号中的block,直到成功.
__block int i = 0;
	[[[RACSignal createSignal:^RACDisposable *(id subscriber) {
		if (i == 10) {
			[subscriber sendNext:@1];
		}else{
			NSLog(@"接收到错误");
			[subscriber sendError:nil];
		}
		i++;
		return nil;
		
	}] retry] subscribeNext:^(id x) {
		
		NSLog(@"%@",x);
	} error:^(NSError *error) {
	}];
复制代码

throttle

  • 节流:当某个信号发送比较频繁时,可以使用节流,在某一段时间不发送信号内容,过了一段时间获取信号的最新内容发出。
UIButton *btn = [UIButton buttonWithType:UIButtonTypeCustom];
	btn.frame = CGRectMake(50, 100, 50, 50);
	btn.backgroundColor = [UIColor greenColor];
	[self.view addSubview:btn];
	
	[[[[btn rac_signalForControlEvents:UIControlEventTouchUpInside] takeUntil:[self rac_willDeallocSignal]] throttle:1] subscribeNext:^(id x) {
		NSLog(@"222222");
	}];
复制代码
关注下面的标签,发现更多相似文章
评论