RACSignal类基本使用
基本的执行流程：
1.创建信号（实际返回的是保存了didSubscribe的RACDynamicSignal对象）
+ (RACSignal *)createSignal:(RACDisposable * (^)(id<RACSubscriber> subscriber))didSubscribe
2.订阅信号（创建订阅者并将订阅者作为参数传入RACDynamicSignal对象的subscribe:方法->subscribe:内部调用信号的didSubscribe(传入订阅者）
- (RACDisposable *)subscribeNext:(void (^)(id x))nextBlock
3.发送信号：didSubscribe内一定要使用传入的订阅者发送信号：即调用订阅者的sendNext:方法，该方法内部会调用订阅者的nextBlock接收值。
- (void)sendNext:(id)value
// 1.创建信号：实际创建的是保存了didSubscribe的RACDynamicSignal对象。
RACSignal *signal = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
// 3.发送信号：方法内部会调用订阅者中保存的nextBlcok。
[subscriber sendNext:@1];
return [RACDisposable disposableWithBlock:^{
// 当信号取消订阅的时候就会调用
NSLog(@"信号被取消订阅");
}];
}];
// 2.订阅信号：生成保存了nextBlock的订阅者对象。
// 2.1 signal对象保存的didSubscribe被调用,传入的参数是订阅者对象
// 2.2 didSubscribe中调用了订阅者的nextBlock来接收值
RACDisposable *disposable = [signal subscribeNext:^(id x) {
NSLog(@"11%@",x);
}];
NSLog(@"%@",disposable);
// 取消订阅
[disposable dispose];
}
RACSubject类基本使用
基本执行流程：
1.创建信号：返回RACSubject类型的对象
+ (instancetype)subject
2.订阅信号：创建订阅者并将订阅者作为参数传入RACSubject对象的subscribe:方法）->订阅者保存在RACSubject对象的subscribers数组中
- (RACDisposable *)subscribeNext:(void (^)(id x))nextBlock
3.发送信号：遍历RACSubject对象的subscribers数组调用订阅者的sendNext:方法发送信号—>调用订阅者的nextBlock接收值
- (void)sendNext:(id)value
// 信号提供者:既可以充当信号,也可以充当订阅者,发送数据
// 一个信号允许被多次订阅
// 1.创建信号：创建subject对象该对象有个subscribers数组用来保存订阅者
RACSubject *subject = [RACSubject subject];
// 2.订阅信号：创建保存了nextBlock的订阅者，并保存到subject的subscribers数组中
[subject subscribeNext:^(id x) {
NSLog(@"订阅者一%@",x);//调用时刻：subject发送信号时调用
}];
[subject subscribeNext:^(id x) {
NSLog(@"订阅者二%@",x);
}];
// 3.发送信号：遍历subject的subscribers数组，调用订阅者的nextBlock接收值
[subject sendNext:@1];
RACReplaySubject基本使用
基本执行流程一：创建信号->发送信号->将值保存到值数组并遍历信号的订阅者数组发送信号—>调用订阅者的nextBlock接收值
基本执行流程二：创建型号->订阅信号—> 创建订阅者
已发送过信号：遍历信号的值数组让订阅者逐一发出->调用订阅者的nextBlock接收值
未发送过信号：将订阅者保存到信号的订阅者数组->发送信号->将值保存到数组并遍历信号的订阅者数组发送信号—>调用订阅者的nextBlock接受值
// 重复信号提供者
// 1.创建信号：subject对象有个valuesReceived数组用来保存值
RACReplaySubject *subject = [RACReplaySubject subject];
// 2.发送信号
// 1. 把值保存到valuesReceived数组
// 2. 遍历所有的订阅者,调用订阅者的next属性（block对象）
[subject sendNext:@"123123"];
[subject sendNext:@"345"];
[subject sendNext:@"456456"];
// 3.订阅信号，
// 1.生成保存了nextBlock的订阅者
// 2.如果subject发送过信号将遍历valuesReceived所有值,调用订阅者的nextBlock来接收值
// 3.如果subject没有发送过信号，即valuesReceived数组为空，订阅者将会被保存，以后一旦subject发送信号，就会遍历订阅者数组，调用订阅者的nextBlock接收值
[subject subscribeNext:^(id x) {
NSLog(@"订阅者一%@",x);
}];
[subject subscribeNext:^(id x) {
NSLog(@"订阅者二%@",x);
}];
RACMulticastConnection类基本使用
基本执行流程：创建信号（RACDynamicSignal对象）->创建RACMulticastConnection对象（创建RACSubject为该对象的signal，设置RACDynamicSignal对象为该对象的sourceSignal）- >把RACSubject对象作为信号订阅—>创建RACSubscriber对象（nextBlock保存在该对象中）作为订阅者保存在RACSubject对象subscribers数组中->使用RACSubject对象订阅信号（RACDynamicSignal对象）->执行RACDynamicSignal对象的didSubscriber并传入RACSubject对象作为订阅者->RSASubject对象遍历订阅者数组subscribers发送信号->调用RACSubscriber对象的nextBlock
//1.创建信号：返回保存了didSubscribe的RACDynamicSignal对象
RACSignal *signal = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
NSLog(@"发送请求");
// 3.发送信号
// 1. RSASubject对象遍历订阅者数组subscribers发送值
// 2. 调用订阅者对象的nextBlock接收值
[subscriber sendNext:@"网络数据"];
return nil;
}];
// 2.把信号转换成连接类:先创建RACSubject对象，然后通过传入RACSubject对象和RACDynamicSignal对象创建RACMulticastConnection对象
RACMulticastConnection *connect = [signal publish];
// 3.订阅连接类的信号,注意:一定是订阅连接类的signal属性信号,不再是源信号
// 1.创建RACSubscriber作为订阅者，并将nextBlock保存到RACSubscriber对象。
// 2.将订阅者保存在RACSubject对象的subscribers数组中
[connect.signal subscribeNext:^(id x) {
NSLog(@"%@",x);
}];
[connect.signal subscribeNext:^(id x) {
NSLog(@"%@",x);
}];
[connect.signal subscribeNext:^(id x) {
NSLog(@"%@",x);
}];
// 4.连接
// 1. 将subject对象设置为sourceSignal信号（RACDynamicSignal对象）的订阅者
// 2. 执行sourceSignal信号即RACDynamicSignal对象保存的block：didSubscribe，block中传入的是subject对象
[connect connect];
RACCommand类基本使用
基本执行流程：创建命令(signalBlock保存在命令中）->执行命令->调用命令中的signalBlock(返回一个RACDynamicSignald对象)->创建RACMulticastConnection对象（创建RACReplaySubject对象作为signal，根据之前创建的RACDynamicSignald对象生成一个新的RACDynamicSignald对象作为sourceSignal，sourceSignal的didSubscribe中保存了调用原来的RACDynamicSignald对象的didSubscribe的代码）->使用命令的
addedExecutionSignalsSubject（RACSubject对象）发送信号，发送的值是RACMulticastConnection对象的signal对象即：RACReplaySubject对象->执行sourceSignal的didSubscribe ->执行了signalBlock中返回的RACDynamicSignald对象的didSubscribe(传入的参数是RACMulticastConnection对象的signal即RACReplaySubject对象）->RACReplaySubject对象发送信号（
把值保存起来,遍历所有的订阅者发送这个值）->调用RACSubscriber对象的nextBlock
后续执行流程：使用RACReplaySubject对象订阅信号（生成订阅者，使用订阅者遍历值数组发送）
// RACCommand使用注意点:内部不允许传入一个nil的信号
// 1.创建命令
RACCommand *command = [[RACCommand alloc] initWithSignalBlock:^RACSignal *(id input) {
// signalBlock调用时刻:只要命令一执行就会调用
// signalBlock作用:处理事件
NSLog(@"%@",input);
return [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
NSLog(@"didSubscribe");
NSLog(@"didSubscribe");
// didSubscribe调用时刻:执行命令过程中,就会调用
// didSubscribe作用:传递数据
// subscriber -> [RACReplaySubject subject]
// RACReplaySubject:把值保存起来,遍历所有的订阅者发送这个值
[subscriber sendNext:@1];
return nil;
}];
}];
// 2.执行命令：
RACReplaySubject *replaySubject = (RACReplaySubject *)[command execute:@"执行命令"];
// 3.获取命令中产生的数据,订阅信号
[replaySubject subscribeNext:^(id x) {
NSLog(@"%@",x);
}];
// 1.创建订阅者,订阅信号
// 2.遍历所有值,拿到订阅者去发送
/* 执行流程:
// 1.创建命令
* 把signalBlock保存到命令中(RACCommand对象中)
// 2.执行命令
* 执行signalBlock（返回RACSignal对象，RACSignal对象保存了blcok对象：didSubscribe）
* 创建多点传播连接类, 订阅源信号（didSubscribe执行）,并且设置源信号的订阅者为RACReplaySubject
* 返回源信号的订阅者
*/