1.RACMulticastConnection
:用于当一个信号,被多次订阅时,为了保证创建信号时,避免多次调用创建信号中的block,造成副作用,可以使用这个类处理。
2.使用注意
:RACMulticastConnection通过RACSignal的-publish或者-muticast:方法创建.
RACMulticastConnection使用步骤:
1.创建信号+ (RACSignal *)createSignal:(RACDisposable * (^)(id<RACSubscriber> subscriber))didSubscribe
2.创建连接RACMulticastConnection *connect = [signal publish];
3.订阅信号,注意:订阅的不在是之前的信号,而是连接的信号。[connect.signal subscribeNext:nextBlock]
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.2didSubscribe,拿到订阅者调用sendNext,其实是调用RACSubject的sendNext
4.RACSubject的sendNext,会遍历RACSubject所有订阅者发送信号。
4.1因为刚刚第二步,都是在订阅RACSubject,因此会拿到第二步所有的订阅者,调用他们的nextBlock
需求:假设在一个信号中发送请求,每次订阅一次都会发送请求,这样就会导致多次请求。
解决:使用RACMulticastConnection就能解决.
@H_404_240@
- -(void)test//普通写法,这样的缺点是:没订阅一次信号就得重新创建并发送请求,这样很不友好
- {
- RACSignal*signal=[RACSignalcreateSignal:^RACDisposable*(id<RACSubscriber>subscriber){
- //didSubscribeblock中的代码都统称为副作用。
- //发送请求---比如afn
- NSLog(@"发送请求啦");
- //发送信号
- [subscribersendNext:@"ws"];
- returnnil;
- }];
- [signalsubscribeNext:^(idx){
- NSLog(@"%@",x);
- }];
- [signalidx){
- NSLog(@"%@",x);
- }
- -(void)test2{//比较好的做法。使用RACMulticastConnection,无论有多少个订阅者,无论订阅多少次,我只发送一个。
- //1.发送请求,用一个信号内包装,不管有多少个订阅者,只想发一次请求
- //发送请求
- NSLog(@"发送请求啦");
- //发送信号
- [subscribersendNext:@"ws"];
- nil;
- //2.创建连接类
- RACMulticastConnection*connection=[signalpublish];
- [connection.signal [connection.signal//3.连接。只有连接了才会把信号源变为热信号
- [connectionconnect];
- }