概念
RAC全称-ReactiveCocoa，是GitHub上的一个开源框架，普遍称之为“函数的响应式编程”，想详细了解什么为什么叫做函数式响应编程，看 袁峥的这边文章https://www.jianshu.com/p/87ef6720a096
源码阅读
RAC主要的类
1、RACSignal （信号类）
①通过RACSignal一个信号，但创建出来的是冷信号
②通过订阅者订阅这个信号，让其变成热信号
③发送信号
2、RACDisposable，它可以帮助我们取消订阅，在信号发送完毕，失败都可以，就类似通知结束后销毁通知一样效果
3、RACSubscriber，是一个协议类，订阅者，发送信号
4、RACSubject：信号提供者，可以自己充当信号，自己可以发送信号，拥有RACSignal和RACSubscriber两者功能。
RACSignal简单用法，了解源码实现原理
1.创建信号
看看信号创建时源码是如何实现的，做了什么，点进creteSignal查看源码，1.png和2.png，就是源码的实现，主要就是创建了一个RACDynamicSignal(继承于RACSignal)的信号类，并且把传进去的didSubscribe代码块保存起来。
2.订阅信号
看看订阅信号时[signal subscribeNext:^(id x)] { } 源码是怎么实现。
订阅信号时主要做了两件事:
1.也是把传进去的block保存了.由3.png和4.png可以看出订阅信号时做的事
2.回调刚开始创建信号时的blcok，也就是 真正实现第3步骤：发送信号 看图5.png和6.png
3.发送信号
- (void)sendNext:(id)value {
@synchronized (self) {
void (^nextBlock)(id) = [self.next copy];
if (nextBlock == nil) return;
nextBlock(value);
}
}
发送信号的源码就是，先上锁，然后传进来的blcok不为nil时，回调订阅信号时的block，把信息发出。
以上就是RACSignal信号类源码所做的时候，也可以知道1.为什么不订阅信号，是无法发送信号的困惑，可能阐述得不太清晰，我们可以看一下下面这张流程图，按照这张流程图一步步的了解RACSignal源码的实现
RACDisposable实现原理
![]()
可以看到的是: 这个返回值是RACDisposable类型的, 然后我们创建一个RACDisposable对象是用+ (instancetype)disposableWithBlock:(void (^)(void))block这个类方法, 同样参数也是一个block, 但是这个block很快就被调用了, 这是为什么呢?
因为当subscriber调用完sendNext后，生命周期结束后会释放，然后调用dealloc
- (void)dealloc {
[self.disposable dispose];
}
这时候,这段代码中的打印就会执行了.
return [RACDisposable disposableWithBlock:^{
NSLog(@"订阅被取消");
}];
return disposable;
同理，如果想要订阅不被自动取消，就让subscriber被强引用时, dealloc方法不被调用, disposable也不会被调用.
如果subscriber被强引用时, 我又想取消订阅, 应该怎么做呢?
subscribeNext:这个方法是有返回值的, 这个返回值其实就是上面didSubscribeblock的返回值(可以先这么理解)
那么最后知道RACDisposable是做什么用的吧?
这个类可以帮助我们取消订阅, 当信号发送完毕了或者失败了之后取消订阅, 并调用指定的代码. 做想处理的释放操作
RACSubscriber实现原理
[signal subscribeNext:^(id x) {
//x:信号发送的内容
NSLog(@"x:%@",x);
}];
- (RACDisposable *)subscribeNext:(void (^)(id x))nextBlock {
NSCParameterAssert(nextBlock != NULL);
RACSubscriber *o = [RACSubscriber subscriberWithNext:nextBlock error:NULL completed:NULL];
return [self subscribe:o];
}
+ (instancetype)subscriberWithNext:(void (^)(id x))next error:(void (^)(NSError *error))error completed:(void (^)(void))completed {
RACSubscriber *subscriber = [[self alloc] init];
subscriber->_next = [next copy];
subscriber->_error = [error copy];
subscriber->_completed = [completed copy];
return subscriber;
}
subscriber订阅时，就是创建subscriber并把穿进去的nextBlock保存。
当subscriber发消息是调用sendNext时：如下
- (void)sendNext:(id)value {
@synchronized (self) {
void (^nextBlock)(id) = [self.next copy];
if (nextBlock == nil) return;
nextBlock(value);
}
}
订阅时保存的nextBlock回调 nextBlock(value)，这就是订阅信号时和发送信号时所做的操作和原理。
RACSubject实现原理
在RAC中, RACSubject类非常重要, 也很特殊, 这个类即可以创建信号, 也可以发送信号
// 1、创建subject信号
RACSubject *subject = [RACSubject subject];
// 2、订阅信号
//RACSubject处理订阅:拿到之前的_subscribers保存订阅者
[subject subscribeNext:^(id x) {
NSLog(@"订阅的信号内容：%@",x);
}];
// 3、发送信号
//遍历出所有的订阅者,调用nextBlock
[subject sendNext:@"123"];
1.在创建信号的时候: 这个框架重写了 init方法，并且创建了一个可变数组_subscribers. 这个可变数组是用来添加 subscriber的
+ (instancetype)subject {
return [[self alloc] init];
}
- (id)init {
self = [super init];
if (self == nil) return nil;
_disposable = [RACCompoundDisposable compoundDisposable];
_subscribers = [[NSMutableArray alloc] initWithCapacity:1];
return self;
}
2.订阅信号时：拿到之前的_subscribers保存订阅者
- (RACDisposable *)subscribe:(id<RACSubscriber>)subscriber {
NSCParameterAssert(subscriber != nil);
RACCompoundDisposable *disposable = [RACCompoundDisposable compoundDisposable];
subscriber = [[RACPassthroughSubscriber alloc] initWithSubscriber:subscriber signal:self disposable:disposable];
NSMutableArray *subscribers = self.subscribers;
@synchronized (subscribers) {
[subscribers addObject:subscriber];
}
return [RACDisposable disposableWithBlock:^{
@synchronized (subscribers) {
// Since newer subscribers are generally shorter-lived, search
// starting from the end of the list.
NSUInteger index = [subscribers indexOfObjectWithOptions:NSEnumerationReverse passingTest:^ BOOL (id<RACSubscriber> obj, NSUInteger index, BOOL *stop) {
return obj == subscriber;
}];
if (index != NSNotFound) [subscribers removeObjectAtIndex:index];
}
}];
}
3.发送信号时, 会遍历这个数组, 把里面的 subscriber一一取出来, 分别发送信号:
- (void)enumerateSubscribersUsingBlock:(void (^)(id<RACSubscriber> subscriber))block {
NSArray *subscribers;
@synchronized (self.subscribers) {
subscribers = [self.subscribers copy];
}
for (id<RACSubscriber> subscriber in subscribers) {
block(subscriber);
}
}
#pragma mark RACSubscriber
- (void)sendNext:(id)value {
[self enumerateSubscribersUsingBlock:^(id<RACSubscriber> subscriber) {
[subscriber sendNext:value];
}];
}
所以, 用 RACSubject的好处就是: 可以订阅多个信号, 最后发送信号的时候一起调用.
看看RACSubject流程图，了解RACSubject原理后就知道为何RACSubject是RACSignal和RACSubcriber的结合体了
