之前有提到过RACSignal是不具备发送信号的能力的,
但是RACSubject这个类就可以做到订阅/发送为一体。
之前还提到过RAC三部曲,在RACSuject中同样适用。
然后我们先创建一个简单的代码段,然后接着分析分析。
//1创建信号,
RACSubject * subject = [RACSubject subject];
//2订阅信号
[subject subscribeNext:^(id _Nullable x) {
NSLog(@"%@",x);
}];
//3发送数据
[subject sendNext:@"发送数据"];
创建信号能做什么
从上图中可以很直观的看到 调用subject
方法内部事创建了一个_disposable
取消信号和一个数组_subscribers
,这个数组从命名上就可以看出来这个数组事,用来保存订阅者。
然后是订阅信号
- (RACDisposable *)subscribeNext:(void (^)(id x))nextBlock {
NSCParameterAssert(nextBlock != NULL);
RACSubscriber *o = [RACSubscriber subscriberWithNext:nextBlock error:NULL completed:NULL];
return [self subscribe:o];
}
这里是创建一个订阅者,然后调用 [self subscribe:o]
方法,
还记得在RACSignal
中也调用了这个方法,
但是需要注意的是这两个方法并不是一个方法,内部实现不一样。
选中这个方法进去
在订阅的时候会把订阅者会把订阅者保存到一开始创建RACSubject
中的数组_subscribers
中。
最后是发布信息
[subject sendNext:@"发送数据"];
选中这个方法进去
总结:
1、创建的subject
的是内部会创建一个数组_subscribers
用来保存所有的订阅者
2、订阅信息的时候会创建订阅者,并且保存到数组中
3、遍历subject
中_subscribers
中的订阅者,依次发送信息
所以对于RACSignal
不同的地方是:他可以被订阅多次,并且只能是先订阅后发布。
从上面的代码中可以明确的看到,第一次发送的字符串是没有收到的,所以证明了RACSubject
只能订阅之后,发送数据才收到
然后我们订阅多次信号,然后发送数据,我们可以看到收到了两次数据。
最后还有一个小问题,那就是如果我非要先发送在订阅,并且也要能收到怎么处理呢?
当然是有办法的啦
RACReplaySubject
,他继承RACSubject
,他的目的就是为例解决上面必须先订阅后发送的问题。
一样的三行代码,运行出来的结果遇上面的不一致, 是时候来一波分析了:
1 创建信号
还记得RACSubject
就是在init
中做了初始化,不记得就到文章开头开开,所以我们直接看他对init
做了啥处理吧
2 发送信号
- (void)sendNext:(id)value {
@synchronized (self) {
[self.valuesReceived addObject:value ?: RACTupleNil.tupleNil];
[super sendNext:value];
if (self.capacity != RACReplaySubjectUnlimitedCapacity && self.valuesReceived.count > self.capacity) {
[self.valuesReceived removeObjectsInRange:NSMakeRange(0, self.valuesReceived.count - self.capacity)];
}
}
}
可以看到代码中在发送之前做了一件事情,把要发送的数据保存到数组中,然后调用父类的发送方法,发送玩了看发送成功了没,成功了就删除数据,避免一个数据多次发送。