Reactive ObjC 的使用 「进阶」

ReactiveObjC 的使用

RAC 的核心思想：创建信号 - 订阅信号 - 发送信号 ，并且在 RAC 中我们会看到大量的 block ，所以在使用之前可以再重新温习一下 block 的使用。

1. RACSignal 信号

<code>
/* 创建信号 */
RACSignal *signal = [RACSignal createSignal:^RACDisposable * _Nullable(id<racsubscriber>  _Nonnull subscriber) {
    
    /* 发送信号 */
    [subscriber sendNext:@"发送信号"];
    
    return nil;
}];
 
/* 订阅信号 */
RACDisposable *disposable = [signal subscribeNext:^(id  _Nullable x) {
    
    NSLog(@"信号内容：%@", x);
}];
 
/* 取消订阅 */
[disposable dispose];/<racsubscriber>/<code>

2. RACSubject 信号

和代理的用法类似，通常用来代替代理，有了它，就不必要定义代理了。

<code>
/* 创建信号 */
RACSubject *subject = [RACSubject subject];
 
/* 发送信号 */
[subject sendNext:@"发送信号"];
 
/* 订阅信号（通常在别的视图控制器中订阅，与代理的用法类似） */
[subject subscribeNext:^(id  _Nullable x) {
    
    NSLog(@"信号内容：%@", x);
}];/<code>

3. RACTuple 元祖

RAC 的元祖，跟我们 OC 的数组其实是一样的，它其实就是封装了我们 OC 的数组。

<code>
/* 创建元祖 */
RACTuple *tuple = [RACTuple tupleWithObjects:@"1", @"2", @"3", @"4", @"5", nil];
 
/* 从别的数组中获取内容 */
RACTuple *tuple = [RACTuple tupleWithObjectsFromArray:@[@"1", @"2", @"3", @"4", @"5"]];
 
/* 利用 RAC 宏快速封装 */
RACTuple *tuple = RACTuplePack(@"1", @"2", @"3", @"4", @"5");
 
NSLog(@"取元祖内容：%@", tuple[0]);
NSLog(@"第一个元素：%@", [tuple first]);
NSLog(@"最后一个元素：%@", [tuple last]);/<code>

4. 便利 Array 数组和 Dictionary 字典

可以省去使用 for 循环来遍历。

<code>
/* 遍历数组 */
NSArray *array = @[@"1", @"2", @"3", @"4", @"5"];
[array.rac_sequence.signal subscribeNext:^(id  _Nullable x) {
    
    NSLog(@"数组内容：%@", x); // x 可以是任何对象
}];/<code>

<code>/* 遍历字典 */
NSDictionary *dictionary = @{@"key1":@"value1", @"key2":@"value2", @"key3":@"value3"};
[dictionary.rac_sequence.signal subscribeNext:^(RACTuple * _Nullable x) {
    
    RACTupleUnpack(NSString *key, NSString *value) = x; // x 是一个元祖，这个宏能够将 key 和 value 拆开
    NSLog(@"字典内容：%@:%@", key, value);
}];/<code>

下面两个方法都是将数组内容全部换为 0 ，第一个是单个操作，，第二个是一次性全部替换，两个方法都不会改变原数组内容，操作完后都会生成一个新的数组，省去了创建可变数组然后遍历出来单个添加的步骤。

<code>/* 内容操作 */
NSArray *array = @[@"1", @"2", @"3", @"4", @"5"];
NSArray *newArray = [[array.rac_sequence map:^id _Nullable(id  _Nullable value) {
    
    NSLog(@"数组内容：%@", value);
    
    return @"0"; // 将所有内容替换为 0
    
}] array];/<code>

<code>/* 内容快速替换 */
NSArray *array = @[@"1", @"2", @"3", @"4", @"5"];
NSArray *newArray = [[array.rac_sequence mapReplace:@"0"] array]; // 将所有内容替换为 0/<code>

5. 监听 TextField 的输入改变

可以省去设置 delegate 和实现代理方法的步骤。

<code>/* 监听 TextField 的输入（内容改变就会调用） */
[[textField rac_textSignal] subscribeNext:^(NSString * _Nullable x) {
    
    NSLog(@"输入框内容：%@", x);
}];/<code>

<code>
/* 添加监听条件 */
[[textField.rac_textSignal filter:^BOOL(NSString * _Nullable value) {
    
    return value.length > 5; // 表示输入文字长度 > 5 时才会调用下面的 block 

    
}] subscribeNext:^(NSString * _Nullable x) {
     
     NSLog(@"输入框内容：%@", x);
}];/<code>

6. 监听 Button 点击事件

可以省去 addTarget 添加事件和创建方法的步骤。

<code>[[button rac_signalForControlEvents:UIControlEventTouchUpInside] subscribeNext:^(__kindof UIControl * _Nullable x) {
   
    NSLog(@"%@ 按钮被点击了", x); // x 是 button 按钮对象
}];/<code>

7. 登录按钮状态实时监听

下面表示只有 用户名 和 密码 输入框内容都大于 0 时，登录 按钮才可以点击，而且状态是实时监听的，一句代码就能完成这个功能。

<code>
RAC(_loginButton, enabled) = [RACSignal combineLatest:@[_username.rac_textSignal, _password.rac_textSignal] reduce:^id _Nullable(NSString * username, NSString * password){
    
    return @(username.length && password.length);
}];/<code>

8. 监听 Notification 通知事件

可省去在 -(void)dealloc {} 中清除通知和监听通知创建方法的步骤。

<code>
[[[NSNotificationCenter defaultCenter] rac_addObserverForName:UIKeyboardDidShowNotification object:nil] subscribeNext:^(NSNotification * _Nullable x) {
    
    NSLog(@"%@ 键盘弹起", x); // x 是通知对象
}];/<code>

9. 代替 Delegate 代理方法

可以省去监听以及设置 delegate 的步骤，下面表示只要 view 中执行了 btnClick 这个方法，就会发送信号执行这个回调。

<code>
[[view rac_signalForSelector:@selector(btnClick)] subscribeNext:^(RACTuple * _Nullable x) {
 
    NSLog(@" view 中的按钮被点击了");
}];/<code>

10. 代替 KVO 监听

可以代替 KVO 监听，下面表示把监听 view 的 frame 属性改变转换成信号，只要值改变就会发送信号。

<code>[[view rac_valuesForKeyPath:@"frame" observer:self] subscribeNext:^(id  _Nullable x) {
    
    NSLog(@"属性的改变：%@", x); // x 是监听属性的改变结果
}];/<code>

还有一种更简单的写法，就是利用 RAC 的宏，和上面的效果是一样的。

<code>[RACObserve(view, frame) subscribeNext:^(id  _Nullable x) {
    
    NSLog(@"属性的改变：%@", x); // x 是监听属性的改变结果
}];/<code>

11. 代替 NSTimer 计时器

可以代替 NSTimer 使用。

<code>
@interface ViewController ()
 
@property (nonatomic, strong) RACDisposable *disposable;
  

@end/<code>

<code>
/* 定义计时器监听 */
self.disposable = [[RACSignal interval:1.0 onScheduler:[RACScheduler mainThreadScheduler]] subscribeNext:^(NSDate * _Nullable x) {
    
    NSLog(@"当前时间：%@", x); // x 是当前的系统时间
    
    /* 关闭计时器 */
    [_disposable dispose];
}];/<code>

OC + RAC(一) RACSignal 基本使用

<code>-(void)_test1{
    
    
    //测试RAC流程 发送next类型事件 以completed结束时:
    //至于有无 sendCompleted 的区别主要是用在需要知道信号状态


    NSLog(@"1 信号未被创建");
    
    RACSignal *sourceSignal = [RACSignal createSignal:^RACDisposable * _Nullable(id<racsubscriber>  _Nonnull subscriber) {
        
        NSLog(@"3 信号被激活，开始发送事件");
        
        [subscriber sendNext:@""];
        
        [subscriber sendCompleted];
        
        return [RACDisposable disposableWithBlock:^{
            
            NSLog(@"6 订阅流程结束，可清理资源");
            
        }];
    }];
     

    NSLog(@"2 信号已被创建，未被订阅（未激活）");
    
    [sourceSignal subscribeNext:^(id  _Nullable x) {
        
        NSLog(@"4 信号已被订阅，可接收next类型事件");
        
        NSLog(@"接收到next类型事件 : %@",x);
        
    } error:^(NSError * _Nullable error) {
        
        NSLog(@"接收到error类型事件：%@",error);
        
    } completed:^{
        
        NSLog(@"5. 接收到completed类型事件");
    }];
    
    
}/<racsubscriber>/<code>

閱讀更多 風箏科技前沿 的文章

關鍵字: Objective-C 进阶 使用