首先得知道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!
