ReactiveObjc 的下载

   首先你的Mac 设备需要下载好CocoaPod、配置好Git，这个我就不细说了，在百度上很多。

① 终端输入一下指令
//搜索ReactiveObjc的最新版本 
pod search ReactiveObjc

②把最新版本，CocoaPod考入到Podfile文件中
pod 'ReactiveObjC', '~> 3.1.0'

③ 在终端 切换到当前项目文件中
cd  /Users/huanggang/Documents/HGSWB

④ 执行下载更新指令，在下载之前最好把 Podfile.lock文件删除，若没有就不用删除了
pod update --verbose

完成安装以后，在需要使用的项目文件中导入文件：#import <ReactiveObjC.h>

---

RACSubject

RACSubject 与 RACCommand 的区别

RACSubject 与 RACCommand 的区别 图示

   RACSubject只能单向发送事件，发送者将事件发送出去让接收者接收事件后进行处理。所以，RACSubject可代替代理，被监听者可利用subject发送事件，监听者接收事件然后进行相应的监听处理，不过，事件的传递方向是单向的。

   对于RACCommand，我觉得用HTTP请求能够更形象地说明其原理，HTTP请求是由请求者向服务器发送一条网络请求，而服务器接收到请求然后经过相应处理后再向请求者返回处理过后的结果，数据流是双向的，RACCommand正是如此，让我想让某个部件进行某种会产生结果的操作时，利用RACCommand向此部件发送执行事件，部件接收到执行事件后进行相应操作处理并也通过RACCommand将操作结果回调到上层，使得事件得以双向流通。

- (void)testReactive {
    RACSubject *searchSubjuct = [RACSubject subject];
    
    [searchSubjuct subscribeNext:^(id  _Nullable x) {
        NSLog(@"订阅信号： %@", x);
    }];
    
    [searchSubjuct sendNext:@"welcome to my home"];
}

打印结果：

2018-11-21 11:26:31.507642+0800 HGSWB[3233:107079] 订阅信号： welcome to my home

---

RACCommand

What is RACCommand

两种创建方式

//①
//通过传进一个用于构建RACSignal的block参数来初始化RACCommand，而block中的参数input为执行command时传入的数据，另外，创建出的signal可在里面完成一些数据操作，如网络请求，本地数据库读写等等
- (instancetype)initWithSignalBlock:(RACSignal<ValueType> * (^)(InputType _Nullable input))signalBlock;

//使用规则：
#a.创建命令 initWithSignalBlock:(RACSignal * (^)(id input))signalBlock

#b.在signalBlock中，创建RACSignal，并且作为signalBlock的返回值

#c.执行命令 - (RACSignal *)execute:(id)input


//②
//传进一个能传递BOOL事件的RACSignal，这个signal的作用相当于过滤，当传递的布尔事件为真值时，command能够执行，反之则不行。
- (instancetype)initWithEnabled:(nullable RACSignal<NSNumber *> *)enabledSignal signalBlock:(RACSignal<ValueType> * (^)(InputType _Nullable input))signalBlock;

属性

RACCommand 通常用来表示某个Action的执行，比如点击Button。它有几个比较重要的属性：executionSignals / errors / executing。

a、executionSignals: 是signal of signals，如果直接subscribe的话会得到一个signal，而不是我们想要的value，所以一般会配合switchToLatest。

b、errors: 跟正常的signal不一样，RACCommand的错误不是通过sendError来实现的，而是通过errors属性传递出来的。

c、executing: 表示该command当前是否正在执行。

Demo

- (void)testReactive {
    //注意：当前命令内部发送数据完成，一定要主动发送完成
    // 1.创建命令
    RACCommand *command = [[RACCommand alloc] initWithSignalBlock:^RACSignal *(id input) {
        // block调用：执行命令的时候就会调用
        NSLog(@"%@", input);
        // 这里的返回值不允许为nil
        return [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
            // 发送数据
            [subscriber sendNext:@"执行命令产生的数据"];
            
            // *** 发送完成 **
            [subscriber sendCompleted];
            return nil;
        }];  
    }];
    // 监听事件有没有完成
    [command.executing subscribeNext:^(id x) {
        if ([x boolValue] == YES) { // 正在执行
            NSLog(@"当前正在执行%@", x);
        }else {
            // 执行完成/没有执行
            NSLog(@"执行完成/没有执行");
        }
    }];
    
    // 2.执行命令
    [command execute:@"welcome  to  my home!!"];
    
}

普通做法

- (void)testReactive {
    // RACCommand: 处理事件
    // 不能返回空的信号
    // 1.创建命令
    RACCommand *command = [[RACCommand alloc] initWithSignalBlock:^RACSignal * _Nonnull(id  _Nullable input) {
        
        //block调用，执行命令的时候就会调用
        NSLog(@"%@",input); // input 为执行命令传进来的参数
        // 这里的返回值不允许为nil ,如果不想要传递信号，直接创建空的信号[RACSignal empty];
        return [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
            [subscriber sendNext:@"执行命令产生数据"];
            //操作完成后发送完成消息以表示其执行完了,否则永远处于执行中
            [subscriber sendCompleted];
            return nil;
        }];
    }];
    
    
    // 如何拿到执行命令中产生的数据呢？
    // 订阅命令内部的信号
    // ** 方式一：直接订阅执行命令返回的信号
    
    // 2.执行命令
    RACSignal *signal = [command execute:@"welcome to my Home"];// 这里其实用到的是replaySubject 可以先发送命令再订阅
    
    // 在这里就可以订阅信号了
    [signal subscribeNext:^(id  _Nullable x) {
        NSLog(@"%@", x);
    }];
}

打印结果：

2018-11-21 17:09:12.896750+0800 HGSWB[10066:392674] welcome to my Home
2018-11-21 17:09:41.202123+0800 HGSWB[10066:392674] 执行命令产生数据

一般做法

- (void)testReactive {
    // 1.创建命令
    RACCommand *command = [[RACCommand alloc] initWithSignalBlock:^RACSignal *(id input) {
        //block调用，执行命令的时候就会调用
        NSLog(@"%@",input); // input 为执行命令传进来的参数
        // 这里的返回值不允许为nil
        return [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
            [subscriber sendNext:@"执行命令产生的数据"];
            [subscriber sendCompleted];
            return nil;
        }];
    }];
    
   
    /*
    // 方式二：
    //一般做法
    // 订阅信号
    // 注意：这里必须是先订阅才能发送命令
    // executionSignals：信号源，信号中信号，signalofsignals:信号，发送数据就是信号
    [command.executionSignals subscribeNext:^(RACSignal *x) {
        [x subscribeNext:^(id x) {
            NSLog(@"%@", x);
        }];
    }];

    */

    //方法三
    //高级做法
    // switchToLatest获取最新发送的信号，只能用于信号中信号。
    [command.executionSignals.switchToLatest subscribeNext:^(id x) {
        NSLog(@"%@", x);
    }];

    // 2.执行命令
    [command execute:@"welcome  to  my home!!"];

}

打印结果：

2018-11-21 17:17:05.006235+0800 HGSWB[10145:399746] welcome  to  my home!!
2018-11-21 17:17:25.073069+0800 HGSWB[10145:399746] 执行命令产生的数据

注意：方法二和方法三必须县订阅才能执行，而方法一可以先执行，再订阅。

注意: 伴随着command一起构建的signal，记得要在操作完成后发送完成消息以表示其执行完了

[subscriber sendCompleted];

否则不能再执行此command。

UIButton中有属性rac_command用于绑定一个已经创建好的command（其使用在后面讲到），当你使用第二种方式创建command时，button的enable属性会随command的可执行性而改变，意思是当传递布尔事件的信号传递了真值事件，按钮才可使用。另外，当你按下按钮，command开始执行时，按钮的enable被自动设置成了NO，除非command执行完了，怎么判断command执行完成了呢？就是当其伴随的signal发送完成事件的时候（上面提及到）。

注意: 当button的rac_command已经绑定了某个command，而这个command又是以第二种方式初始化，那么你就不能动态改变button的enable，如:

RAC(self.button, enable) = someSignal;

这样子运行起来会报错。（自己曾踩过的坑）

执行 RACCommand

调用函数：

- (RACSignal *)execute:(id)input;

在上面已经提到，input会作为创建command时其内部signal的构建block中的参数，用于传递数据。

---

ReactiveObjc
<b/>

参考资料：iOS RAC - RACSubject、RACReplaySubject
ReactiveCocoa之RACCommand使用(五)
ReactiveObjc 集锦