iOS RAC的实现原理1-RACSignal

首先得知道RAC是什么：
ReactiveCocoa-GitHub

RAC 是什么？

RAC - `ReactiveCocoa` 是一个函数响应式的框架 
GitHub上的开源框架 在5.0以后的版本就是swift的了

集成ReactiveCocoa框架到项目 项目增大2-2.4M
注意纯OC项目目前集成ReactiveObjC (3.0.0)
纯swift项目集成ReactiveCocoa (5.0.3)
至于为什么，就不再做解释了。

现在以OC项目集成为例 
1、创建项目`RAC-demo`
2、终端 cd 到项目 再执行命令
`$ vi Podfile`
3、把下边的复制到Podfile

use_frameworks!
platform :ios, "9.0"

target 'RAC-demo' do
  pod 'ReactiveObjC', '~> 3.1.1'
end

4、执行命令：
$：pod install
5、关闭项目，再次打开xcworkspace后缀的文件编译一下没问题。
OK 下边可以写代码了：

集成后有个报错：iOS 报错：cannot create weak reference in file using

image.png

参考这里https://blog.csdn.net/u010545480/article/details/52995908

6、引入框架的头文件

#import <ReactiveObjC/ReactiveObjC.h>

RACSignal信号类 是RAC里面最常见最常用的类

1、通过这个类创建一个信号RACSignal(默认是冷信号);
2、通过订阅者订阅信号（这个信号变为热信号）;
3、发送信号

 //1、创建一个信号
RACSignal *signal = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        
        //3、发送信号
        //subscriber 发送
        
        [subscriber sendNext:@"发送信号"];
        
        return nil;
    
    }];
//2、订阅信号
    //nextBlock这个block 调用：只要订阅者发送数据就调用
    //nextBlock 作用：处理数据的
    
    [signal subscribeNext:^(id  _Nullable x) {
        
        //x就是信号发送的内容
        
        NSLog(@"订阅的信号是: %@",x);
        
    }];
    //2017-06-13 16:50:11.399 RAC-demo[32406:3606231] 订阅的信号是发送信号

实现的原理如下：

1.创建RACDynamicSignal信号:

[RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {}]

'cmd 点进去'

+ (RACSignal *)createSignal:(RACDisposable * (^)(id<RACSubscriber> subscriber))didSubscribe {
    return [RACDynamicSignal createSignal:didSubscribe];
}
createSignal:点进去：可以发现
@property (nonatomic, copy, readonly) RACDisposable * (^didSubscribe)(id<RACSubscriber> subscriber);

@end

@implementation RACDynamicSignal

#pragma mark Lifecycle

+ (RACSignal *)createSignal:(RACDisposable * (^)(id<RACSubscriber> subscriber))didSubscribe {
    RACDynamicSignal *signal = [[self alloc] init];
    signal->_didSubscribe = [didSubscribe copy];
    return [signal setNameWithFormat:@"+createSignal:"];
}
'将 'didSubscribe' 被 '_didSubscribe'
signal->_didSubscribe = [didSubscribe copy];
保存起来'

保存Block《didSubscribe》

2.订阅信号

创建订阅者
RACSubscriber

'subscribeNext:^(id  _Nullable x)
cmd 点进去'

- (RACDisposable *)subscribeNext:(void (^)(id x))nextBlock {
    NSCParameterAssert(nextBlock != NULL);
    
    RACSubscriber *o = [RACSubscriber subscriberWithNext:nextBlock error:NULL completed:NULL];
    return [self subscribe:o];
}
'subscriberWithNext:nextBlock error:NULL completed:NULL'
'cmd 点进去'
+ (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;
}
'将 'next' 被 '_next'
subscriber->_next = [next copy];'
'保存起来'
保存Block《nextBlock》

2.1 真正订阅信号
'cmd 点进去 [self subscribe:o]'
self ==> RACDynamicSignal

- (RACDisposable *)subscribe:(id<RACSubscriber>)subscriber {
    NSCParameterAssert(subscriber != nil);

    RACCompoundDisposable *disposable = [RACCompoundDisposable compoundDisposable];
    subscriber = [[RACPassthroughSubscriber alloc] initWithSubscriber:subscriber signal:self disposable:disposable];

    if (self.didSubscribe != NULL) {
        RACDisposable *schedulingDisposable = [RACScheduler.subscriptionScheduler schedule:^{
            RACDisposable *innerDisposable = self.didSubscribe(subscriber);
            [disposable addDisposable:innerDisposable];
        }];

        [disposable addDisposable:schedulingDisposable];
    }
    
    return disposable;
}
【实现了第一次调用：执行   didSubscribe】
'self.didSubscribe(subscriber);'

3、发送信号、数据
//subscriber ==RACSubscriber 发送
        
        [subscriber sendNext:@"发送信号"];

'cmd 点进去 sendNext'
- (void)sendNext:(id)value {
    @synchronized (self) {
        void (^nextBlock)(id) = [self.next copy];
        if (nextBlock == nil) return;

        nextBlock(value);
    }
}
【实现了第二次调用：执行   nextBlock】
'nextBlock(value);'

 //x就是信号发送的内容
        
        NSLog(@"订阅的信号是: %@",x);
//Log:2017-06-13 16:50:11.399 RAC-demo[32406:3606231] 订阅的信号是发送信号

流程图示：

实现原理图示

//导入这三个框架。就可以混编了 pod'ReactiveObjC' pod'ReactiveCocoa' pod'ReactiveObjCBridge'之前我一直看网上说要手动假如ReactiveObjCBridge 框架 后面发现直接导入就行中间遇到的问题本来以前是这样导入的 #import "Masonry.h" 改为#import <Masonry/Masonry.h>因为我在pod的时候加了use_frameworks!