记录ReactiveObjC的一些用法

常见用法

rac_signalForSelector : 代替代理
rac_valuesAndChangesForKeyPath: KVO
rac_signalForControlEvents:监听事件
rac_addObserverForName 代替通知
rac_textSignal：监听文本框文字改变
rac_liftSelector:withSignalsFromArray:Signals:当传入的Signals(信号数组)，每一个signal都至少sendNext过一次，就会去触发第一个selector参数的方法。

常见宏

RAC(TARGET, [KEYPATH, [NIL_VALUE]])：用于给某个对象的某个属性绑定
RACObserve(self, name) ：监听某个对象的某个属性,返回的是信号。
@weakify(Obj)和@strongify(Obj)
RACTuplePack ：把数据包装成RACTuple（元组类）
RACTupleUnpack：把RACTuple（元组类）解包成对应的数据
RACChannelTo 用于双向绑定的一个终端

常用操作方法

flattenMap map 用于把源信号内容映射成新的内容。
concat 组合按一定顺序拼接信号，当多个信号发出的时候，有顺序的接收信号
then 用于连接两个信号，当第一个信号完成，才会连接then返回的信号。
merge 把多个信号合并为一个信号，任何一个信号有新值的时候就会调用
zipWith 把两个信号压缩成一个信号，只有当两个信号同时发出信号内容时，并且把两个信号的内容合并成一个元组，才会触发压缩流的next事件。
combineLatest:将多个信号合并起来，并且拿到各个信号的最新的值,必须每个合并的signal至少都有过一次sendNext，才会触发合并的信号。
reduce聚合:用于信号发出的内容是元组，把信号发出元组的值聚合成一个值
filter:过滤信号，使用它可以获取满足条件的信号.
ignore:忽略完某些值的信号.
distinctUntilChanged:当上一次的值和当前的值有明显的变化就会发出信号，否则会被忽略掉。
take:从开始一共取N次的信号
takeLast:取最后N次的信号,前提条件，订阅者必须调用完成，因为只有完成，就知道总共有多少信号.
takeUntil:(RACSignal *):获取信号直到某个信号执行完成
skip:(NSUInteger):跳过几个信号,不接受。
switchToLatest:用于signalOfSignals（信号的信号），有时候信号也会发出信号，会在signalOfSignals中，获取signalOfSignals发送的最新信号。
doNext: 执行Next之前，会先执行这个Block
doCompleted: 执行sendCompleted之前，会先执行这个Block
timeout：超时，可以让一个信号在一定的时间后，自动报错。
interval 定时：每隔一段时间发出信号
delay 延迟发送next。
retry重试：只要失败，就会重新执行创建信号中的block,直到成功.
replay重放：当一个信号被多次订阅,反复播放内容
throttle节流:当某个信号发送比较频繁时，可以使用节流，在某一段时间不发送信号内容，过了一段时间获取信号的最新内容发出。

RACSequence和RACTuple简单使用遍历数组或字典

// 1.遍历数组
    NSArray *numbers = @[@1,@2,@3,@4];
 
    // 这里其实是三步
    // 第一步: 把数组转换成集合RACSequence numbers.rac_sequence
    // 第二步: 把集合RACSequence转换RACSignal信号类,numbers.rac_sequence.signal
    // 第三步: 订阅信号，激活信号，会自动把集合中的所有值，遍历出来。
    [numbers.rac_sequence.signal subscribeNext:^(id x) {
        NSLog(@"%@",x);
    }];
 
 
    // 2.遍历字典,遍历出来的键值对会包装成RACTuple(元组对象)
    NSDictionary *dict = @{@"name":@"xmg",@"age":@18};
    [dict.rac_sequence.signal subscribeNext:^(RACTuple *x) {
 
        // 解包元组，会把元组的值，按顺序给参数里面的变量赋值
        RACTupleUnpack(NSString *key,NSString *value) = x;
 
        // 相当于以下写法
//        NSString *key = x[0];
//        NSString *value = x[1];
        NSLog(@"%@ %@",key,value);
    }];
 
    // 3.字典转模型
    // 3.1 OC写法
    NSString *filePath = [[NSBundle mainBundle] pathForResource:@"flags.plist" ofType:nil];
    NSArray *dictArr = [NSArray arrayWithContentsOfFile:filePath];
    NSMutableArray *items = [NSMutableArray array];
 
    for (NSDictionary *dict in dictArr) {
        FlagItem *item = [FlagItem flagWithDict:dict];
        [items addObject:item];
    }
 
    // 3.2 RAC写法
    NSString *filePath = [[NSBundle mainBundle] pathForResource:@"flags.plist" ofType:nil];
    NSArray *dictArr = [NSArray arrayWithContentsOfFile:filePath];
    NSMutableArray *flags = [NSMutableArray array];
 
    _flags = flags;
 
    // rac_sequence注意点：调用subscribeNext，并不会马上执行nextBlock，而是会等一会。
    [dictArr.rac_sequence.signal subscribeNext:^(id x) {
        // 运用RAC遍历字典，x：字典
        FlagItem *item = [FlagItem flagWithDict:x];
        [flags addObject:item];
    }];
 
    NSLog(@"%@",  NSStringFromCGRect([UIScreen mainScreen].bounds));
 
    // 3.3 RAC高级写法:
    NSString *filePath = [[NSBundle mainBundle] pathForResource:@"flags.plist" ofType:nil];
 
    NSArray *dictArr = [NSArray arrayWithContentsOfFile:filePath];
    // map:映射的意思，目的：把原始值value映射成一个新值
    // array: 把集合转换成数组
    // 底层实现：当信号被订阅，会遍历集合中的原始值，映射成新值，并且保存到新的数组里。
    NSArray *flags = [[dictArr.rac_sequence map:^id(id value) {
        return [FlagItem flagWithDict:value];
    }] array];

RACCommand简单使用

RACCommand使用步骤:

 1.创建命令
    RACCommand *command = [[RACCommand alloc] initWithSignalBlock:^RACSignal *(id input) {
        NSLog(@"执行命令");
        // 创建空信号,必须返回信号
        //        return [RACSignal empty];
 
        // 2.创建信号,用来传递数据
        return [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
            [subscriber sendNext:@"请求数据"];
            // 注意：数据传递完，最好调用sendCompleted，这时命令才执行完毕。
            [subscriber sendCompleted];
            return nil;
        }];
    }];
 
    // 强引用命令，不要被销毁，否则接收不到数据
    _conmmand = command;
 
    // 3.订阅RACCommand中的信号
    [command.executionSignals subscribeNext:^(id x) {
        [x subscribeNext:^(id x) {
            NSLog(@"%@",x);
        }];
    }];
 
    // RAC高级用法
    // switchToLatest:用于signal of signals，获取signal of signals发出的最新信号,也就是可以直接拿到RACCommand中的信号
    [command.executionSignals.switchToLatest subscribeNext:^(id x) {
        NSLog(@"%@",x);
    }];
 
    // 4.监听命令是否执行完毕,默认会来一次，可以直接跳过，skip表示跳过第一次信号。
    [[command.executing skip:1] subscribeNext:^(id x) {
        if ([x boolValue] == YES) {
            // 正在执行
            NSLog(@"正在执行");
        }else{
            // 执行完成
            NSLog(@"执行完成");
        }
    }];
   // 5.执行命令
    [self.conmmand execute:@1];

3.处理多个请求，都返回结果的时候，统一做处理.

    RACSignal *request1 = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
 
        // 发送请求1
        [subscriber sendNext:@"发送请求1"];
        return nil;
    }];
 
    RACSignal *request2 = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
        // 发送请求2
        [subscriber sendNext:@"发送请求2"];
        return nil;
    }];
 
    // 使用注意：几个信号，参数一的方法就几个参数，每个参数对应信号发出的数据。
    [self rac_liftSelector:@selector(updateUIWithR1:r2:) withSignalsFromArray:@[request1,request2]];

}

// 更新UI
- (void)updateUIWithR1:(id)data r2:(id)data1
{
    NSLog(@"更新UI%@  %@",data,data1);
}

分别摘录至
iOS 最全ReactiveCocoa原理及使用方法
 ReactiveCocoa 最全常用API整理

记录ReactiveObjC的一些用法

常见用法

常见宏

常用操作方法

RACSequence和RACTuple简单使用 遍历数组或字典

RACCommand简单使用

推荐阅读更多精彩内容

RACSequence和RACTuple简单使用遍历数组或字典