前言
在这里说说当有多个订阅者,但是我们只想发送一个信号的时候怎么办?
我们就可以用RACMulticastConnection,来实现
先来上demo链接https://github.com/muyang00/YERACDemo.git
RACMulticastConnection使用步骤
- 1、创建信号 +(RACSignal)createSignal
- 2、创建连接 RACMulticastConnection *connect = [signal publish];
- 3、订阅信号,注意:订阅的不再是之前的信号,而是连接的信号 [connect.signal subscribeNext];
- 4、连接 [connect connect];
浅谈RACMulticastConnection底层原理
- 1、 创建connect,connect.sourceSignal -> RACSignal(原始信号) connect.signal -> RACSubject
- 2、 订阅connect.signal,会调用RACSubject的subscribeNext,创建订阅者,而且把订阅者保存起来,不会执行block。
- 3、 [connect connect]内部会订阅RACSignal(原始信号),并且订阅者是RACSubject
3.1、 订阅原始信号,就会调用原始信号中的didSubscribe
3.2、 didSubscribe,拿到订阅者调用sendNext,其实是调用RACSubject的sendNext - 4、 RACSubject的sendNext,会遍历RACSubject所有订阅者发送信号。
4.1、 因为刚刚第二步,都是在订阅RACSubject,因此会拿到第二步所有的订阅者,调用他们的nextBlock
直接上干货了
RACSignal *signal = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
// didSubscribeblock中的代码都统称为副作用。
// 发送请求---比如afn
NSLog(@"发送请求啦");
// 发送信号
[subscriber sendNext:@"信号"];
return nil;
}];
[signal subscribeNext:^(id x) {
NSLog(@"%@", x);
}];
[signal subscribeNext:^(id x) {
NSLog(@"%@", x);
}];
[signal subscribeNext:^(id x) {
NSLog(@"%@", x);
}];
打印结果为:
但是这样有个问题没订阅一次信号就得重新创建并发送请求,这样很不友好
so
使用RACMulticastConnection,无论有多少个订阅者,无论订阅多少次,我只发送一个。
// 1.发送请求,用一个信号内包装,不管有多少个订阅者,只想发一次请求
RACSignal *resignal = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
// 发送请求
NSLog(@"注意啦,我只发一次请求");
// 发送信号
[subscriber sendNext:@"信号"];
return nil;
}];
//2. 创建连接类
RACMulticastConnection *connection = [resignal publish];
[connection.signal subscribeNext:^(id x) {
NSLog(@"%@", x);
}];
[connection.signal subscribeNext:^(id x) {
NSLog(@"%@", x);
}];
[connection.signal subscribeNext:^(id x) {
NSLog(@"%@", x);
}];
//3. 连接。只有连接了才会把信号源变为热信号
[connection connect];
打印结果为:
最后
不积跬步,无以至千里;不积小流,无以成江海