ReactiveCocoa详解

最近看了大神的博客后，感觉该对ReactiveCocoa做一个了断了。

首先大致的对以下关于ReactiveCocoa内容做一个简单的总结，其他的后续更新

　　1.ReactiveCocoa的操作思想

　　2.ReactiveCocoa的底层实现

　　3.ReactiveCocoa的信号映射的使用和底层实现

　　4.ReactiveCocoa的组合信号的使用和底层实现

　　5.ReactiveCocoa的过滤信号的使用和底层实现

　　6.ReactiveCocoa的秩序信号的使用和底层实现

　　7.ReactiveCocoa的线程使用和底层实现

　　8.ReactiveCocoa的时间信号的使用和底层实现

　　9.ReactiveCocoa的重复信号的使用和底层实现

废话不多说，开干就完了，本文的学习思路主要来源于袁峥大神的博客

1.ReactiveCocoa的操作思想

　　ReactiveCocoa运用的是Hook（钩子）细想，就是一种改变API执行结果的技术，在每次执行API之前，先执行你自己的方法，也就意味着可以对源程序就行修改，从而达到改变结果的输出的目的

2.ReactiveCocoa的底层实现

　　bind（绑定）是ReactiveCocoa的核心方法，也是ReactiveCocoa的开发方式，之前的开发方式是赋值，而使用ReactiveCocoa开发后，应该把工作重点放到bind(绑定)上，也就是在创建对象的时候，就可以绑定他以后要做的事情，而不是等赋值后再去考虑。

　　例如：之前我们开发的时候，如果把数据展示到控件上，一般使用setModel的方法，而ReactiveCocoa却在创建控件的时候就绑定好数据，只要数据有变化，就会马上通知控件发生变化

　　2.1 bind方法的简单使用和介绍

　　　　假设我们要监听文本框的内容变化，并且在文本框的内容前面加上'输出'两个字样

　　　　方式一：在返回结果后面拼接'输出'

  [self.textField.rac_textSignal subscribeNext:^(NSString * _Nullable x) {
        NSLog(@"输出：%@",x);
    }];

　　　　方式二：在返回结果前使用ReactiveCocoa的bind方法，对源信号内容进行处理

　　　　bind方法参数：需要传入一个RACSignalBindBlock的block参数，RACSignalBindBlock是一个block类型，返回值是参数为（value,*stop）的信号类型的block

　　　　RACSignalBindBlock:

　　　　参数一（value）：表示接收源信号的值，就是未做处理的值

　　　　参数二（*stop）: 用于控制绑定信号的block,如果*stop = YES,那么就会结束绑定

　　　　返回值：对源信号进行处理后的信号，一般使用RACReturnSignal,需要手动导入<ReactiveCocoa/RACReturnSignal.h>

　　2.2 bind方法使用步骤：

　　　　2.2.1 传入一个RACSignalBindBlock的block

　　　　2.2.2 返回一个RACSignal类型的bindBlock作为block的返回值

　　　　2.2.3 返回一个处理后的结果信号，作为bindBlock的返回值

　　　　注意：在bindBlock中对源信号进行处理

　　2.3 底层实现

　　　　2.3.1 源信号调用bind，会创建一个绑定信号

　　　　2.3.2 当绑定信号被订阅，就会调用绑定信号的didSubscribe，生成一个bindBlock

　　　　2.3.3 当源信号有内容发出时，就是执行bindBlock(value,*stop)

　　　　2.3.4 调用bindBlock(value,*stop)，返回一个处理完成的信号（RACReturnSignal）

　　　　2.3.5 订阅返回信号（RACReturnSignal）,就会拿到绑定信号的订阅者，把处理完成的信号返回出去

　　　　注意：不同的订阅者，生成不同的nextBlock

[[self.textField.rac_textSignal bind:^RACSignalBindBlock _Nonnull{
        //什么时候调用
        //block作用表示绑定了一个信号
        return ^RACSignal *(id _Nullable value,BOOL *stop){
            //当信号有新值发送过来时，就回调用block
            //block作用：对返回值进行处理
            //处理好的结果，通过信号（RACReturnSignal）返回出去
            return [RACReturnSignal return:[NSString stringWithFormat:@"输出：%@",value]];
        };
    }] subscribeNext:^(id  _Nullable x) {
        NSLog(@"%@",x);
    }];

3.ReactiveCocoa的信号映射的使用和底层实现

　   3.1 flattenMap详解

　　　　3.1.1 flattenMap的作用

　　　　　　将源信号转变为新信号

　　　　3.1.2 flattenMap的使用步骤

　　　　　　3.1.2.1 传入一个block作为参数，block是一个参数为（value）返回值为RACSignal的block

　　　　　　3.1.2.2 参数value是源信号的值，需要对源信号的值进行处理

　　　　　　3.1.2.3 将处理后的结果，包装成信号（RACReturnSignal）发送出去

　　　　3.1.3 flattenMap的底层实现

　　　　　　3.1.3.1 flattenMap底层调用的依然是bind方法，flattemMap的block作为bind方法中的bindBlock的返回值

　　　　　　3.1.3.2 当订阅绑定信号时，会调用didSubsribe,生成bindBlock

　　　　　　3.1.3.3 当源信号发送新的内容的时候，会执行bindBlock(value,*stop)

　　　　　　3.1.3.4 当调用bindBlock时，就是调用flattenMap的block,因此对源信号进行处理也是在这个block中进行的，最后把处理结果包装成信号

　　　　　　3.1.3.5 返回的信号最终当作bindBlock返回的信号

　　　　　　3.1.3.6 订阅bindBlock返回的信号，就会获得处理完成的内容

- (void)flattenMap
{
    [[self.textField.rac_textSignal flattenMap:^__kindof RACSignal * _Nullable(NSString * _Nullable value) {
        //block什么时候调用，源信号发出的时候，就会调用这个block
        //block的作用：改变源信号的内容
        //返回值：绑定信号的内容
        return [RACReturnSignal return:[NSString stringWithFormat:@"输出：%@",value]];
    }] subscribeNext:^(id  _Nullable x) {
        //订阅绑定信号，每当源信号发出新内容，做完处理后就会调用这个block
        NSLog(@"%@",x);
    }];
}

　　3.2 map详解

　　　　3.2.1 map信号的作用：把源信号的值映射成新值

　　　　3.2.2 map的使用步骤

　　　　　　3.2.2.1 传入一个返回值为对象的block，参数是value

　　　　　　3.2.2.2 block的参数value就是源信号的值，应该在block中对value进行处理即可

　　　　　　3.2.2.3 把处理好的值直接返回就好，不用返回信号，返回的值就是处理完成的值

　　　　3.2.3 map的底层实现

　　　　　　3.2.3.1 map底层调用的其实还是flattenMap操作，map中的block回作为flattenMap的block值

　　　　　　3.2.3.2 其余同上述的flattenMap底层操作一样，不再赘述

- (void)map
{
    [[self.textField.rac_textSignal map:^id _Nullable(NSString * _Nullable value) {
        //当源信号有新的内容发出，就回调用这个block
        //返回值：处理完源信号内容的值
        return [NSString stringWithFormat:@"输出：%@",value];
    }] subscribeNext:^(id  _Nullable x) {
        NSLog(@"%@",x);
    }];
}

4.ReactiveCocoa的组合信号的使用和底层实现

　　4.1 concat信号

　　　　4.1.1 concat信号作用：按一定顺序拼接信号，当信号发出的时候，按照一定顺序接收信号

　　　　4.1.2 concat底层实现：（以事例中的signalA拼接signalB为例）

　　　　　　4.1.2.1 当拼接信号被订阅，就会调用拼接信号didSubscribe

　　　　　　4.1.2.2 didSubscribe中会先订阅第一个信号源（signalA）

　　　　　　4.1.2.3 执行第一个信号源（signalA）的didSubscribe

　　　　　　4.1.2.4 在第一个信号源（signalA）的didSubscribe中发送值，就会调用第一个信号源（signalA）订阅者的nextBlock，通过拼接信号的订阅者把值发送出去

　　　　　　4.1.2.5 第一个信号源（signalA）的didSuscribe发送完成（sendCompleted），就会执行第一个信号源（signalA）订阅者的completeBlock，第二个信号源（signalB）就会被订阅

　　　　　　4.1.2.6 第二个信号源（signalB）的执行过程如上，不再赘述

　　　　　　注意：必须在第一个信号发送完成（sendCompleted）后，第二个信号才会执行

- (void)concat
{
    RACSignal *signalA = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        [subscriber sendNext:@"A"];
        [subscriber sendNext:@"A2"];
        //注意：必须signalA发送完成信号后才会激活signalB,否侧不会执行signalB
        [subscriber sendCompleted];
        return nil;
    }];

    RACSignal *signalB = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        [subscriber sendNext:@"B"];
        [subscriber sendNext:@"B2"];
        [subscriber sendCompleted];
        return nil;
    }];

    //把signalA拼接到signalB后，signal发送完成后，才会激活signalB
    RACSignal *concatSignal = [signalA concat:signalB];
    //注意：第一个信号完成后，第二个信号才会被激活
    [concatSignal subscribeNext:^(id  _Nullable x) {
        NSLog(@"%@",x);
    }];

}

　　4.2 then信号

　　　　4.2.1 then信号作用：用于连接两个信号，当第一个信号完成（sendCompleted）时，才会连接then返回的信号

　　　　4.2.2 then信号底层实现：

　　　　　　4.2.2.1 过滤掉之前信号发送的值

　　　　　　4.2.2.2 使用concat连接then返回的信号

　　　　　　注意：then之前的信号必须发送完成（sendCompleted）后，才会发出then返回的信号

- (void)then
{
    [[[RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        [subscriber sendNext:@1];
        //注意：then之前的信号必须发送完成（sendCompleted）之后，才会出发then返回的信号
        [subscriber sendCompleted];
        return nil;
    }] then:^RACSignal * _Nonnull{
        return [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
            [subscriber sendNext:@2];
            [subscriber sendCompleted];
            return nil;
        }];
    }] subscribeNext:^(id  _Nullable x) {
        //只能接收第二个信号发送的值，也就是then信号发送的值
        NSLog(@"%@",x);
    }] ;
}

　　4.3 merage信号

　　　　4.3.1 merage信号作用： 把多个信号合并成一个信号，只要有一个信号发生变化，就会调用合并信号

　　　　4.3.2 merage信号底层实现：

　　　　　　4.3.2.1 合并信号被订阅，就会遍历所有的信号

　　　　　　4.3.2.2 合并信号一旦被订阅，合并前的所有信号也会被订阅

　　　　　　4.3.2.3 只要有一个信号发出内容，合并信号就会监听到

- (void)merage
{
    RACSignal *signalA = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {

        [subscriber sendNext:@"A"];
        [subscriber sendCompleted];
        return nil;
    }];

    RACSignal *signalB = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        [subscriber sendNext:@"B"];
        [subscriber sendCompleted];
        return nil;
    }];

    RACSignal *merageSignal = [signalA merge:signalB];

    [merageSignal subscribeNext:^(id  _Nullable x) {
        NSLog(@"%@",x);
    }];
}

　　4.4 zip信号

　　　　4.4.1 zip信号作用： 把两个信号压缩成一个信号，只有两个信号同时发出内容时，才会把两个信号发出的内容压缩成一个元组，从而调用压缩后的信号的nextBlock

　　　　4.4.2 zip信号的底层实现：

　　　　　　4.4.2.1 订阅压缩信号，就相当于订阅了压缩前的所有信号

　　　　　　4.4.2.2 每当有信号发出内容，就会判断是否所有信号都发送出内容，如果都发送出了内容，那就会将其内容压缩成元组，通过压缩信号发送出去

- (void)zipWith
{
    RACSignal *signalA = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        [subscriber sendNext:@"A"];
        [subscriber sendCompleted];
        return nil;
    }];

    RACSignal *signalB = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        [subscriber sendNext:@"B"];
        [subscriber sendCompleted];
        return nil;
    }];

    RACSignal *zipSignal = [signalA zipWith:signalB];

    [zipSignal subscribeNext:^(id  _Nullable x) {
        RACTupleUnpack(NSString *a, NSString *b) = x;
        NSLog(@"%@---%@",a,b);
    }];
}

　　4.5 combinelatest信号

　　　　4.5.1 combinelatest信号作用：合并多个信号，并且拿到每个信号的最新值，必须每个信号至少sendNext一次后，才会发出合并信号，和zip信号一样，没有任何区别

　　　　4.5.2 combineLatest底层实现：

　　　　　　4.5.2.1 同zip底层实现类似

- (void)combineLatest
{
    RACSignal *signalA = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        [subscriber sendNext:@"A"];
        [subscriber sendNext:@"A2"];
        [subscriber sendCompleted];
        return nil;
    }];

    RACSignal *signalB = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        [subscriber sendNext:@"B"];
        [subscriber sendNext:@"B2"];
        [subscriber sendCompleted];
        return nil;
    }];

    RACSignal *signalC = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        [subscriber sendNext:@"C"];
        [subscriber sendNext:@"C2"];
        [subscriber sendCompleted];
        return nil;
    }];

    //把多个信号合并成一个信号，和zip一样，没有什么区别
    [[RACSignal combineLatest:@[signalA,signalB,signalC]] subscribeNext:^(RACTuple * _Nullable x) {
        RACTupleUnpack(NSString *a,NSString *b,NSString *c) = x;
        NSLog(@"%@----%@-----%@",a,b,c);
    }];
}

　　4.6 reduce操作

　　　　4.6.1 reduce操作的作用：用于信号发出的内容是元组，把组合信号发出的元组内容聚合成一个值，并发送出去

　　　　4.6.2 reduce操作底层实现：

　　　　　　4.6.2.1 订阅聚合信号，每次有内容发出，就只执行reduceBlock,把源信号的内容转换成reduceBlock返回的值

- (void)reduce
{
    RACSignal *signalA = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        [subscriber sendNext:@"A"];
        [subscriber sendNext:@"A2"];
        [subscriber sendCompleted];
        return nil;
    }];

    RACSignal *signalB = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        [subscriber sendNext:@"B"];
        [subscriber sendNext:@"B2"];
        [subscriber sendCompleted];
        return nil;
    }];

    [[RACSignal combineLatest:@[signalA,signalB] reduce:^id(NSString *a, NSString *b){
        return [NSString stringWithFormat:@"%@-%@",a,b];
    }] subscribeNext:^(id  _Nullable x) {
        NSLog(@"%@",x);
    }];
}

 5.ReactiveCocoa中过滤信号的使用和底层实现

　　5.1 filter信号操作

　　　　5.1.1 filter信号操作的作用：

　　　　　　过滤信号，获取满足条件的信号

- (void)filter
{
    [[self.textField.rac_textSignal filter:^BOOL(NSString * _Nullable value) {
        return value.length > 2;
    }] subscribeNext:^(NSString * _Nullable x) {
        NSLog(@"%@",x);
    }];
}

　　5.2 ignore信号操作

　　　　5.2.1 ignore信号的作用：

　　　　　　忽略某些值的信号

　　　　5.2.2 底层实现

　　　　　　内部调用filter操作，忽略某些值

- (void)ignore
{
    [[self.textField.rac_textSignal ignore:@"1"] subscribeNext:^(NSString * _Nullable x) {
        NSLog(@"%@",x);
    }];

    [[@[@"213",@"fdsf",@"4534",@"dfd"].rac_sequence.signal ignore:@"dfd"] subscribeNext:^(id  _Nullable x) {
        NSLog(@"%@",x);
    }];
}

　　5.3 distinctUntilChanged信号操作

　　　　5.3.1 distinctUntilChanged信号作用：

　　　　　　当上次信号值和当前信号值有明显变化时才发出信号，否则被忽略掉

　　　　5.3.2 使用场景：

　　　　　　在开发中，刷新UI时经常使用这个信号，只有两次数据不一致才会刷新页面

　　　　注意：distinctUntilChanged是比较上次信号值和当前信号值当比较

- (void)distinctUntilChanged
{
    [[self.textField.rac_textSignal distinctUntilChanged] subscribeNext:^(NSString * _Nullable x) {
        NSLog(@"%@",x);
    }];


    [[@[@"2334",@"dsfsdf",@"dsfsdf",@"dsfsdf",@"2334"].rac_sequence.signal distinctUntilChanged] subscribeNext:^(id  _Nullable x) {
        NSLog(@"%@",x);
    }];

}

　　5.4 take信号操作

　　　　5.4.1 take信号的作用：

　　　　　　一次取几个信号

- (void)take
{
    RACSubject *subject = [RACSubject subject];
    [[subject take:1] subscribeNext:^(id  _Nullable x) {
        NSLog(@"%@",x);
    }];

    [subject sendNext:@1];
    [subject sendNext:@2];
}

　　5.5 takelast信号操作

　　　　5.5.1 takelast信号作用：

　　　　　　取最后第N次信号，前提条件，订阅者必须发送完成信号，因为只有完成才知道总共有几个信号

　　　　注意：订阅者必须调用完成信号，因为只有完成才知道总共有几个信号

- (void)takelast
{
    RACSubject *subject = [RACSubject subject];

    [[subject takeLast:1] subscribeNext:^(id  _Nullable x) {
        NSLog(@"%@",x);
    }];

    [subject sendNext:@1];
    [subject sendNext:@2];

    //注意：订阅者必须调用完成信号，因为只有完成才知道总共有几个信号
    [subject sendCompleted];
}

　　5.6 takeUntil信号操作

　　　　5.6.1 takeUntil信号作用：

　　　　　　获取信号直到某个信号完成

- (void)takeUntil
{
    [[self.textField.rac_textSignal takeUntil:self.rac_willDeallocSignal] subscribeNext:^(NSString * _Nullable x) {
        NSLog(@"%@",x);
    }];
}

　　5.7 skip信号操作

　　　　5.7.1 skip信号作用：

　　　　　　跳过几个信号

 //注意：textField的rac_textSignal默认执行一次，开始编辑执行一次
    [[self.textField.rac_textSignal skip:4] subscribeNext:^(NSString * _Nullable x) {
        NSLog(@"%@",x);
    }];

　　5.8 switchToLatest信号操作

　　　　5.8.1 switchToLatest信号作用：

　　　　　　用于signalOfSignals(信号中的信号)，有的时候也会信号中发送信号

- (void)switchToLatest
{
    RACSubject *signalOfSignals = [RACSubject subject];
    RACSubject *signal = [RACSubject subject];

    [signalOfSignals.switchToLatest subscribeNext:^(id  _Nullable x) {
        NSLog(@"%@",x);
    }];

    [signalOfSignals sendNext:signal];
    [signal sendNext:@1];
    [signal sendNext:@2];
}

6.ReactiveCocoa的秩序信号的使用和底层实现

　　6.1 doNext和doCompleted信号的操作

　　　　6.1.1 doNext和doCompleted信号的作用：

　　　　　　 doNext:执行subscribeNext之前，会先执行这个block
 　　　　　　doCompleted:执行complete之前，会先执行这个block

- (void)doNextAndDoCompleted
{
    [[[[RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        NSLog(@"-----信号被订阅了-----");
        [subscriber sendNext:@"1"];
        [subscriber sendCompleted];
        return nil;
    }] doNext:^(id  _Nullable x) {
        NSLog(@"-----执行doNext-----%@",x);
    }] doCompleted:^{
        NSLog(@"-----执行doCompleted-----");
    }] subscribeNext:^(id  _Nullable x) {
        NSLog(@"-----执行subscribeNext-----");
    } completed:^{
        NSLog(@"-----执行completed-----");
    }] ;
}

7.ReactiveCocoa的线程信号的使用和底层实现

　　7.1 deliverOn信号的操作

　　　　7.1.1 deliverOn信号的作用：

　　　　　　内容传递切换到制定线程中，副作用在原来线程中,把在创建信号时block中的代码称之为副作用

　　7.2 subscribeOn信号的操作

　　　　7.2.1 subscribeOn信号的作用：

　　　　　　内容传递和副作用都会切换到制定线程中。

8.ReactiveCocoa的时间信号的使用和底层实现

　　8.1 retry信号操作

　　　　8.1.1 retry信号的作用：

　　　　　　只要失败，就会重新执行创建信号中的block，直到成功

- (void)retry
{
    __block int num = 1;
    [[[RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        if(num == 10){
            [subscriber sendNext:@(num)];
        }else{
            NSLog(@"-----异常处理-----");
            [subscriber sendError:nil];
        }
        num++;
        return nil;
    }] retry] subscribeNext:^(id  _Nullable x) {
      NSLog(@"-----执行了subscribeNext-----%@",x);
    } error:^(NSError * _Nullable error) {
        NSLog(@"-----执行了error-----");
    }];

　　8.2 replay信号操作

　　　　8.2.1 replay信号的作用

　　　　　　当一个信号被多次订阅时，反复播放内容。由此可以，信号是懒惰的，不订阅是不会执行的，下面例子如果不加replay,则第二个订阅者输出则是2，加上replay后，第一个订阅者和第二个订阅者输出都是1

- (void)replay
{
    __block int num = 1;
    RACSignal *signal = [[RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        [subscriber sendNext:@(num++)];
        [subscriber sendCompleted];
        return nil;
    }] replay];

    [signal subscribeNext:^(id  _Nullable x) {
        NSLog(@"-----第一个订阅者-----%@",x);
    }];

    [signal subscribeNext:^(id  _Nullable x) {
        NSLog(@"-----第二个订阅者-----%@",x);
    }];
}

　　8.3 throttle信号操作

　　　　8.3.1 throttle信号的作用：

　　　　　　当一个信号发送比较频繁时，可以使用节流，在某一时间段内不发送信号

- (void)throttle
{
    RACSubject *signal = [RACSubject subject];
    //节流 在一定时间内，不接收任何信号，过了这个时间获取最后发送的信号内容
    [[signal throttle:1] subscribeNext:^(id  _Nullable x) {
        NSLog(@"-----执行了subscribeNext-----%@",x);
    }];

    [signal sendNext:@1];
    [signal sendNext:@2];
    [signal sendNext:@3];
}

至此，ReactiveCocoa的基本操作就总结到这里，后期会继续更新ReactiveCocoa的更多的操作