iOS RAC学习之路（二）

前言

之前对RAC有了一个基本的认识，了解了它的作用，以及RAC的运行机制，我们知道只要是信号（RACSignal），我们就能对它进行一顿订阅，然后执行触发操作；接下来我们来学习一下RAC中常用的类以及一系列的用法。

RACSignal

这是一个信号类，表示一个信号源，只要有数据改变就会把数据包装成信号传递出去，它本身不具备发送信号的能力，而是交给内部的一个订阅者(RACSubscriber)去发出，然后当信号被订阅之后，就会在其内部就创建一个订阅者，所以在信号内部就可以发送信号了，之前也对RACSignal做了一个简单的了解，下面学习一下更多的用法

  • 常用事件处理
  • Target-Action
 [[btn rac_signalForControlEvents:UIControlEventTouchUpInside] subscribeNext:^(__kindof UIControl * _Nullable x) {
        //x==btn
        NSLog(@"%@",x);
        [self push];
 }];
  • Delegate
//因为订阅信号是void返回类型的，所以只能代替void返回类型的delegate
[textField.rac_textSignal subscribeNext:^(NSString * _Nullable x) {
        //x==textField.text
        NSLog(@"%@",x);
}];
  • KVO
//直接用宏
[RACObserve(self.view, backgroundColor) subscribeNext:^(id  _Nullable x) {
        //x==新背景颜色
        NSLog(@"%@",x);
 }];
//也可以这样
__weak typeof(self) weakSelf = self;
 [[self.view rac_valuesForKeyPath:@"backgroundColor" observer:weakSelf] subscribeNext:^(id  _Nullable x) {
        NSLog(@"%@",x);
 }];
  • 通知
[[[NSNotificationCenter defaultCenter] rac_addObserverForName:UIKeyboardWillShowNotification object:nil] subscribeNext:^(NSNotification * _Nullable x) {
        //x==userInfo
        NSLog(@"%@",x);
 }];
  • 常用方法
  • flattenMap，map
    这是两个映射方法，将源信号内容映射成新的内容，就像signal管道上的中间处理器，从这里走过的signal都会经过一段处理后，变成新的signal继续传输。
//map，将输出NSNumber的signal转换成输出NSString
RACSignal *mapSignal = [[RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {

        [subscriber sendNext:@(1)];
        return nil;
    }] map:^id _Nullable(id  _Nullable value) {

        return [NSString stringWithFormat:@"%@",value];
    }];
    [mapSignal subscribeNext:^(id  _Nullable x) {
        //NSString类型
        NSLog(@"x");
    }];

//flattenMap，将输出NSNumber的signal转换成输出NSString
RACSignal *mapSignal = [[RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        [subscriber sendNext:@(1)];
        return nil;
        
    }] flattenMap:^__kindof RACSignal * _Nullable(id  _Nullable value) {
        
        return [RACReturnSignal return:[NSString stringWithFormat:@"%@",value]];
    }];
    [mapSignal subscribeNext:^(id  _Nullable x) {
        //NSString类型
        NSLog(@"x");
    }];

两者之间的区别就在于，map中Block返回转换对象，flattenMap返回转换对象的信号。一般信号发出的值不是信号，使用map；如果是信号则使用flattenMap，它可以处理信号中的信号。

  • merge：把多个信号合并成一个信号，只需订阅这一个信号就相当于订阅了多个信号，任何一个信号有新值的时候都会触发调用。
RACSignal *signal1 = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        [subscriber sendNext:@(1)];
        return nil;
    }];
    RACSignal *signal2 = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        [subscriber sendNext:@(2)];
        return nil;
    }];
    RACSignal *signal3 = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        [subscriber sendNext:@(3)];
        return nil;
    }];
    RACSignal *mergeSignal = [RACSignal merge:@[signal1,signal2,signal3]];
    [mergeSignal subscribeNext:^(id  _Nullable x) {
        //分别输出1,2,3
        NSLog(@"%@",x);
    }];
  • concat：将多个信号有顺序的连接起来，按照顺序接收信号，但是一定要之前的信号完成了才能发送下一个信号。
RACSignal *signal1 = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        [subscriber sendNext:@(1)];
        //发送信号完成，表示不再订阅了，内部会自动调用[RACDisposable disposable]取消订阅信号。
        [subscriber sendCompleted];
        return nil;
    }];
    RACSignal *signal2 = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        [subscriber sendNext:@(2)];
        [subscriber sendCompleted];
        return nil;
    }];
    RACSignal *signal3 = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        [subscriber sendNext:@(3)];
        [subscriber sendCompleted];
        return nil;
    }];
    RACSignal *concatSignal = [RACSignal concat:@[signal2,signal1,signal3]];
    [concatSignal subscribeNext:^(id  _Nullable x) {
        //分别输出2,1,3
        NSLog(@"%@",x);
    }];
  • then：用于连接两个信号，内部也是使用concat，当前一个信号完成之后才会连接then返回的信号，但是会忽略前一个信号，只会触发下个信号。
    RACSignal *signal1 = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        [subscriber sendNext:@(1)];
        [subscriber sendCompleted];
        return nil;
    }];
   RACSignal *thenSignal =  [signal1 then:^RACSignal * _Nonnull{
      return  [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
           [subscriber sendNext:@(2)];
           [subscriber sendCompleted];
           return nil;
       }];
   }];
    [thenSignal subscribeNext:^(id  _Nullable x) {
        //输出2
        NSLog(@"%@",x);
    }];
  • zip：将对各信号压缩成一个信号，只有当几个信号同时sendNext的时候才会触发压缩流的next事件，其中每一个信号send的内容都是一一对应的。
    RACSignal *signal1 = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        [subscriber sendNext:@(1)];
        //不会覆盖上一个信号
        [subscriber sendNext:@(3)];
        return nil;
    }];
    RACSignal *signal2 = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        
        [subscriber sendNext:@(2)];
        return nil;
    }] ;
    RACSignal *zipSignal = [RACSignal zip:@[signal1,signal2]];
    [zipSignal subscribeNext:^(id  _Nullable x) {
        //输出(1,2)
        NSLog(@"%@",x);
    }];
  • combineLatest：将多个信号组合起来，当其中每一个信号都sendNext之后，才会触发组合的信号，其中每一个信号再次sendNext都会覆盖之前的信号内容，返回的是一个RACTuple（元组，类似于NSArray）。
    RACSignal *signal1 = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        [subscriber sendNext:@(1)];
        //将覆盖之前的信号，这就是跟zip的区别
        [subscriber sendNext:@(3)];
        return nil;
    }];
    RACSignal *signal2 = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        [subscriber sendNext:@(2)];
        return nil;
    }];
   //如果其中一个信号不sendNext，则不会触发组合信号
    RACSignal *combineSignal = [RACSignal combineLatest:@[signal1,signal2] ];
    [combineSignal subscribeNext:^(id  _Nullable x) {
        //输出(3,2)
        NSLog(@"%@",x);
    }];
  • rac_liftSelector: withSignalsFromArray:：当信号组中每一个信号都至少一次sendNext之后，将触发Selector方法，类似于combineLatest。
    RACSubject *subject1 = [RACSubject subject];
    RACSubject *subject2 = [RACSubject subject];
    [[self rac_liftSelector:@selector(updateWithParameter1:parameter2:) withSignals:subject1,subject2, nil] subscribeNext:^(id  _Nullable x) {
        NSLog(@"%@",x);
    }];
    [subject1 sendNext:@1];
    [subject2 sendNext:@2];
  • reduceEach：一般用于元组，把元组的值聚合成一个值。
RACSignal *combineSignal = [RACSignal combineLatest:@[signal1,signal2] ];
    RACSignal *reduceSignal = [combineSignal reduceEach:^id (NSNumber *num1,NSNumber *num2){
        return @(num1.doubleValue+num2.doubleValue);
    }];
    [reduceSignal subscribeNext:^(id  _Nullable x) {
        //输出3
        NSLog(@"%@",x);
    }];
//等同于+ (RACSignal *)combineLatest:(id<NSFastEnumeration>)signals reduce:(id (^)())reduceBlock
//    RACSignal *combineSignal = [RACSignal combineLatest:@[signal1,signal2] reduce:^id (NSNumber *num1,NSNumber *num2){
//        return @(num1.doubleValue+num2.doubleValue);
//    }];
  • filter：过滤信号，添加筛选条件，只有符合的才会触发调用。
RACSignal *signal1 = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        [subscriber sendNext:@(1)];
        [subscriber sendNext:@"3"];
        return nil;
    }];
    RACSignal *filterSignal = [signal1 filter:^BOOL(id  _Nullable value) {
        return [value isKindOfClass:[NSNumber class]];
    }];
    [filterSignal subscribeNext:^(id  _Nullable x) {
        //输出1
        NSLog(@"%@",x);
    }];
    
    //数组的筛选
    RACSequence *sequence = [@[@(1),@(2),@"3"].rac_sequence filter:^BOOL(id  _Nullable value) {
        return [value isKindOfClass:[NSNumber class]];
    }];
    [sequence.signal subscribeNext:^(id  _Nullable x) {
        //输出1，2
        NSLog(@"%@",x);
    }];
  • distinctUntilChanged：当前值跟上一次的值不同的时候，就会触发调用，否则被忽略。
[textField.rac_textSignal.distinctUntilChanged subscribeNext:^(NSString * _Nullable x) {
        //变化时输出变化之后的值
        NSLog(@"%@",x);
    }];
  • take：从第一个信号开始设置信号发送的有效的个数。
    RACSignal *signal = [[RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        [subscriber sendNext:@(1)];
        [subscriber sendNext:@(2)];
        return nil;
    }] take:1];
    
    [signal subscribeNext:^(id  _Nullable x) {
        //输出1，因为take为1，所以有效的只有最开始的那一个，其他的忽略掉了
        NSLog(@"%@",x);
    }];
  • takeLast：从最后一个开始设置信号发送的有效个数，必须sendCompleted，不然不知道总共多少个信号。
    [[[RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        [subscriber sendNext:@(1)];
        [subscriber sendNext:@(2)];
        [subscriber sendCompleted];
        return nil;
    }] takeLast:1] subscribeNext:^(id  _Nullable x) {
        //输出2
        NSLog(@"%@",x);
    }];
  • takeUntil：[signal1 takeUntil:signal2]，当signal2已经sendNext或者sendCompleted，signal1就会失效。
    RACSignal *signal1 = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        [subscriber sendNext:@(1)];
        return nil;
    }];
    RACSignal *signal2 = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        [subscriber sendNext:@(2)];
        return nil;
    }];
    [[signal1 takeUntil:signal2] subscribeNext:^(id  _Nullable x) {
        //什么都不会输出，因为signal2已经sendNext，所以signal1就会失效
        NSLog(@"%@",x);
    }];
  • skip：跳跃，从第一个发出的信号开始跳。
[[[RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        [subscriber sendNext:@(1)];
        [subscriber sendNext:@(2)];
        [subscriber sendNext:@(3)];
        return nil;
    }] skip:2] subscribeNext:^(id  _Nullable x) {
        //输出3
        NSLog(@"%@",x);
    }];
  • doNext：在执行sendNext之前会执行这个。
[[[RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        [subscriber sendNext:@(1)];
        return nil;
    }] doNext:^(id  _Nullable x) {
        x = [NSString stringWithFormat:@"%@haha",x];
        //输出1haha，在订阅回调之前执行
        NSLog(@"%@",x);
    }] subscribeNext:^(id  _Nullable x) {
        //输出1
        NSLog(@"%@",x);
    }];
  • timeout：在超过设定时间范围之后让信号报错，且不能发送内容。
    RACSubject *subject = [RACSubject subject];
    [[subject timeout:3 onScheduler:[RACScheduler mainThreadScheduler]] subscribeNext:^(id  _Nullable x) {
        //只输出1
        NSLog(@"%@",x);
    } error:^(NSError * _Nullable error) {
        //3秒之后输出错误日志
        NSLog(@"%@",error);
    }];
    [subject sendNext:@1];
    dispatch_after(dispatch_time(DISPATCH_TIME_NOW, (int64_t)(4 * NSEC_PER_SEC)), dispatch_get_main_queue(), ^{
        [subject sendNext:@2];
    });
  • interval：定时，每隔一定时间发出时间信号。
//RACScheduler:队列
[[RACSignal interval:1 onScheduler:[RACScheduler currentScheduler]] subscribeNext:^(NSDate * _Nullable x) {
        //每隔一秒输出当前时间
        NSLog(@"%@",x);
}];
  • delay：延时发送信号
    [[[RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        [subscriber sendNext:@(1)];
        return nil;
    }] delay:3] subscribeNext:^(id  _Nullable x) {
        //3秒之后输出1
        NSLog(@"%@",x);
    }];
  • retry：重试，只要失败，就会重新执行创建信号中的block,直到成功。
    __block NSInteger i = 0;
    [[[RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        i++;
        if (i > 10) {
            [subscriber sendNext:@(1)];
        }else{
            [subscriber sendError:nil];
        }
        return nil;
    }] retry] subscribeNext:^(id  _Nullable x) {
        //重试10次之后输出1
        NSLog(@"%@",x);
    }error:^(NSError * _Nullable error) {
        NSLog(@"%@",error);
    }];
  • throttle：节流，当某个信号发送比较频繁的时候，可以限制在一定之间内不接受信号，等过了这个时间再取最后发送的信号内容发出，类似于bufferWithTime:onScheduler:。
    RACSubject *subject = [RACSubject subject];
// [subject bufferWithTime:1 onScheduler:[RACScheduler currentScheduler]];
    [[subject throttle:1] subscribeNext:^(id  _Nullable x) {
        //输出3，拿到最后发出的内容3
        NSLog(@"%@",x);
    }];
    [subject sendNext:@1];
    [subject sendNext:@2];
    [subject sendNext:@3];
  • deliverOn：内容传递切换到指定线程中，副作用在原来线程中,把在创建信号时block中的代码称之为副作用。
  • subscribeOn：内容传递和副作用都会切换到指定线程中。

RACSubject

信号提供者，本身可以充当信号，又能发送信号，继承自RACSignal，但是底层实现跟RACSignal有些不一样，当订阅信号的时候会创建订阅者并保存订阅响应Block，而发送信号的时候会遍历订阅者，然后分别调用nextBlock。它提供的API很少，但是经常使用，因为它继承自RACSignal。这里顺便来看一下方法 flatten跟switchToLatest，这两个都只能用来处理信号中的信号。

  • flatten：压平信号中的信号，信号中的信号我们称之为子信号，flatten可以拿到所有子信号发送的值。
RACSubject *subject = [RACSubject subject];
RACSubject *subSubject1 = [RACSubject subject];
RACSubject *subSubject2 = [RACSubject subject];
[subject subscribeNext:^(id  _Nullable x) {
    //分别输出subSubject1，subSubject2，但是不能拿到其中的值
    NSLog(@"%@",x);
}];
[subject.flatten subscribeNext:^(id  _Nullable x) {
    //分别输出1，2, flatten可以拿到所有子信号发送的值
    NSLog(@"%@",x);
}];
[subject sendNext:subSubject1];
[subject sendNext:subSubject2];
[subSubject1 sendNext:@1];
[subSubject2 sendNext:@2];
  • switchToLatest：与flatten相同，压平信号中的信号，不同的是，在存在多个子信号时候只会拿到最新的子信号，然后输出最新的子信号的值。
RACSubject *subject = [RACSubject subject];
RACSubject *subSubject1 = [RACSubject subject];
RACSubject *subSubject2 = [RACSubject subject];
[subject subscribeNext:^(id  _Nullable x) {
    //分别输出subSubject1，subSubject2，但是不能拿到其中的值
    NSLog(@"%@",x);
}];
[subject.switchToLatest subscribeNext:^(id  _Nullable x) {
    //输出2, switchToLatest只会拿到最新的子信号发送的值
    NSLog(@"%@",x);
}];
[subject sendNext:subSubject1];
[subject sendNext:subSubject2];
[subSubject1 sendNext:@1];
[subSubject2 sendNext:@2];

RACReplaySubject

重复提供信号类，继承自RACSubject，它可以先发送信号，再订阅信号，原理就是将发送的信号内容保存了起来，当订阅信号的时候再将之前保存的信号，由订阅者一个一个的发送出来，而保存信号的容量由capacity来控制。

 RACReplaySubject *replaySubject = [RACReplaySubject replaySubjectWithCapacity:5];
 [replaySubject subscribeNext:^(id  _Nullable x) {
     //输出1
     NSLog(@"%@",x);
 }];
 [replaySubject sendNext:@1];
 [replaySubject subscribeNext:^(id  _Nullable x) {
     //输出1
     NSLog(@"%@",x);
 }];

RACMulticastConnection

这是一个组播连接类，是对信号的一个封装处理，当一个信号被多次订阅时，则会多次执行didSubscribe这个Block，造成副作用，而这个类就能避免多次执行didSubscribe，是一对多的单向数据流，一般用来处理信号被多次订阅的情况。

__block int i = 0;
//创建信号
RACSignal *signal = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
    [subscriber sendNext:@(i)];
    i ++;
    return nil;
}];
//创建RACMulticastConnection对象
RACMulticastConnection *connect = [signal publish]
 [connect.signal subscribeNext:^(id  _Nullable x) {
    //输出0
    NSLog(@"%@",x);
}];
[connect.signal subscribeNext:^(id  _Nullable x) {
    //输出0,当再次订阅时，不会再执行didSubscribe，所以并没有i++
    NSLog(@"%@",x);
}];
//连接
[connect connect];
  • 方法解析及实现原理
  • publish，multicast：这是对RACMulticastConnection初始化方法的一个封装，publish其实就是调用了multicast，并把创建好的RACSubject对象传给它，而multicast也就是调用了RACMulticastConnection的初始化方法，将原始信号传给source，把RACSubject对象传给subject。
  • 当我们订阅connect.signal，其实就是订阅subject，然后将subject的订阅者保存起来，而调用[connect connect]的时候，会订阅原始信号（source），而source的订阅者就是subject，这时候subject就会执行[subject sendNext]，之后就会遍历subject所有的订阅者，逐一发送信号，触发外部subscribeNext回调。

RACCommand

这是一个命令类，可以把事件如何处理，事件中的数据如何传递，包装到这个类中，他可以很方便的监控事件的执行过程，一般来说是在UI上的某些动作来触发这些事件，比如点击一个按钮，RACCommand的实例能够决定是否可以被执行，一般用于网络请求，监控请求过程。

  • 公开的属性及方法
@interface RACCommand: NSObject

//这是一个二阶信号，表示信号中包含子信号，一般使用flatten或switchToLatest来降阶
@property (nonatomic, strong, readonly) RACSignal<RACSignal<ValueType> *> *executionSignals;

//这个信号表示当前RACCommand是否正在执行，YES/NO
@property (nonatomic, strong, readonly) RACSignal<NSNumber *> *executing;

//这个信号表示RACCommand是否可用，如果初始化传NO或者allowsConcurrentExecution=NO，那个这个信号返回NO，否则为YES
@property (nonatomic, strong, readonly) RACSignal<NSNumber *> *enabled;

//表示RACCommand执行过程中产生的错误信号，当对错误信号进行处理的时候应该subscribeNext去订阅，而不是subscribeError。
@property (nonatomic, strong, readonly) RACSignal<NSError *> *errors;

//是否允许并发执行，默认为NO
@property (atomic, assign) BOOL allowsConcurrentExecution;

/**
 初始化
 @param signalBlock 返回信号的Block,在其内部进行保存，当进行execute的时候才会调用该Block
 @return self
 */
- (instancetype)initWithSignalBlock:(RACSignal<ValueType> * (^)(InputType _Nullable input))signalBlock;

/**
 初始化
 @param enabledSignal 是否可用
 @param signalBlock 返回信号的Block,在其内部进行保存，当进行execute的时候才会调用该Block
 @return self
 */
- (instancetype)initWithEnabled:(nullable RACSignal<NSNumber *> *)enabledSignal signalBlock:(RACSignal<ValueType> * (^)(InputType _Nullable input))signalBlock;

/**
 执行
 @param input 输出内容
 @return 组播连接对象的signal
 */
- (RACSignal<ValueType> *)execute:(nullable InputType)input;

@end
  • 使用步骤：
  1. 创建命令，初始化RACCommand对象，内部做的事情：
  • 将传入的signalBlock进行保存
  • 初始化自己的4个信号，executionSignals，executing，enabled，errors。
  1. 在signalBlock中创建RACSignal，用来做数据传递，如果不需要可以创建空信号[RACSignal empty]。
  2. 执行命令execute，内部做的事情：
  • 调用之前保存的signalBlock，并将execute参数带入进去，拿到signalBlock返回的信号。
  • 再将该信号内容切换到主线程，然后multicast成RACMulticastConnection对象，避免多次订阅导致重复创建信号。
  • 将connection.signal map到executionSignals，当原始信号发送数据的时候，通过switchToLatest或flatten来降阶取值。
  //1.创建命令对象
  RACCommand *command = [[RACCommand alloc] initWithSignalBlock:^RACSignal *(id input) {
      //输出1,由execute传入
      NSLog(@"%@",input);
      //2.创建信号
      return [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
          [subscriber sendNext:@(2)];
          // 注意：数据传递完，最好调用sendCompleted，这时命令才执行完毕。
          [subscriber sendCompleted];
          return nil;
      }];
  }];

  //获取信号传输的数据
  [command.executionSignals.switchToLatest subscribeNext:^(id x) {
      //输出2
      NSLog(@"%@",x);
  }];
  //这里用flatten跟switchToLatest也是一样的
  [[command.executionSignals flatten] subscribeNext:^(id  _Nullable x) {
      //输出2
      NSLog(@"%@",x);
  }];

  //监听命令是否执行完毕,初始化时会调用一次，用skip直接跳过。
  [[command.executing skip:1] subscribeNext:^(id x) {
      if ([x boolValue] == YES) {
          // 正在执行
          NSLog(@"正在执行");
      }else{
          // 执行完成
          NSLog(@"执行完成");
      }
  }];

  //3.执行命令
  RACSignal *connectSignal = [command execute:@1] ;
  [connectSignal subscribeNext:^(id  _Nullable x) {
      //输出2，connectSignal是connect.signal
      NSLog(@"%@",x);
  }];

RACChannel

这是一个通道类，可以理解为一个双向的连接，连接的两端都配有RACChannelTerminal（通道终端，继承自RACSignal，且又实现了RACSubscriber协议，所以它可以充当信号，又能发送信号），分别是leadingTerminal，followingTerminal，只要其中任何一端输出信号，另一端都会有相同的信号输出。我们平时很少直接使用RACChannel，而是使用RACChannelTo。

  • RACChannelTo：使用这个宏要传入相关对象以及它的属性，比如RACChannelTo(view,backgroundColor)，实际上创建了一个RACKVOChannel对象，在内部将其一端的leadingTerminal与view的backgroundColor属性进行绑定，并将其另一端followingTerminal暴露出来，也就是RACChannelTo的返回值，我们可以对followingTerminal进行订阅，拿到view. backgroundColor，同样followingTerminal发送信号也会同步到view.backgroundColor。

  • 用它来实现双向绑定，RACChannelTo(button,backgroundColor) = RACChannelTo(view,backgroundColor);将button跟view的背景颜色进行绑定，两边相互影响，进行同步。

    RACChannelTerminal *followT = RACChannelTo(view,backgroundColor);
    [followT subscribeNext:^(id  _Nullable x) {
        //每点击一次就输出一次随机颜色
        NSLog(@"%@",x);
    }];
    UITapGestureRecognizer *tap = [[UITapGestureRecognizer alloc]init];
    [tap.rac_gestureSignal subscribeNext:^(__kindof UIGestureRecognizer * _Nullable x) {
        //改变view.backgroundColor
        [followT sendNext:RandomColor];
    }];

    //将_textField.backgroundColor跟view.backgroundColor绑定
    RACChannelTo(button,backgroundColor) = RACChannelTo(view,backgroundColor);

常用宏

  • RAC(TARGET, ...)：给某个对象的某个属性进行绑定。
  //当textfield开始编辑时，关闭button响应
 RAC(_button,enabled) = [[self rac_signalForSelector:@selector(textFieldDidBeginEditing:) fromProtocol:@protocol(UITextFieldDelegate)] mapReplace:@NO];
  • RACObserve(TARGET, KEYPATH)：KVO，监听某个对象的属性，返回的是信号。
[RACObserve(self.view, backgroundColor) subscribeNext:^(id  _Nullable x) {
    //x==新背景颜色
    NSLog(@"%@",x);
}];
  • RACChannelTo：用于双向绑定的一个通道终端。
//将_textField.backgroundColor跟view.backgroundColor绑定
  RACChannelTo(button,backgroundColor) = RACChannelTo(view,backgroundColor);
  • RACTuplePack：将数据包装成RACTuple（元组）。
RACTuple *tuple = RACTuplePack(@1,@2,@"3");
  • RACTupleUnpack(...)：把元组解包成对应的数据
 //传入需要解析生成的变量名，从第一个开始解析
 RACTupleUnpack(NSNumber *num1,NSNumber *num2) = tuple;
 //输出1，2
 NSLog(@"%@,%@",num1,num2);
最后编辑于 ：
©著作权归作者所有,转载或内容合作请联系作者
  • 人面猴
    序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
    沈念sama阅读 206,839评论 6赞 482
  • 死咒
    序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
    沈念sama阅读 88,543评论 2赞 382
  • 救了他两次的神仙让他今天三更去死
    文/潘晓璐 我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
    开封第一讲书人阅读 153,116评论 0赞 344
  • 道士缉凶录：失踪的卖姜人
    文/不坏的土叔 我叫张陵，是天一观的道长。 经常有香客问我，道长，这世上最难降的妖魔是什么？ 我笑而不...
    开封第一讲书人阅读 55,371评论 1赞 279
  • 港岛之恋（遗憾婚礼）
    正文 为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
    茶点故事阅读 64,384评论 5赞 374
  • 恶毒庶女顶嫁案：这布局不是一般人想出来的
    文/花漫 我一把揭开白布。 她就那样静静地躺着，像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上，一...
    开封第一讲书人阅读 49,111评论 1赞 285
  • 城市分裂传说
    那天，我揣着相机与录音，去河边找鬼。 笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。 我是一名探鬼主播，决...
    沈念sama阅读 38,416评论 3赞 400
  • 双鸳鸯连环套：你想象不到人心有多黑
    文/苍兰香墨 我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
    开封第一讲书人阅读 37,053评论 0赞 259
  • 万荣杀人案实录
    序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
    沈念sama阅读 43,558评论 1赞 300
  • 护林员之死
    正文 独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 36,007评论 2赞 325
  • 白月光启示录
    正文 我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 38,117评论 1赞 334
  • 活死人
    序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
    沈念sama阅读 33,756评论 4赞 324
  • 日本核电站爆炸内幕
    正文 年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
    茶点故事阅读 39,324评论 3赞 307
  • 男人毒药：我在死后第九天来索命
    文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 30,315评论 0赞 19
  • 一桩弑父案，背后竟有这般阴谋
    文/苍兰香墨 我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,539评论 1赞 262
  • 情欲美人皮
    我被黑心中介骗来泰国打工， 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。 一个月前我还...
    沈念sama阅读 45,578评论 2赞 355
  • 代替公主和亲
    正文 我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
    茶点故事阅读 42,877评论 2赞 345

推荐阅读更多精彩内容