RAC基础笔记

RACSignal:

信号类，当数据改变的时候，内部会发出信号，本身不能发送信号，而是交给一个订阅者（RACSubscriber）去发送，创建的时候block内部会带一个订阅者。

RACSubscriber:

订阅者，本身是个协议，用于发送信号，

RACDisposable：

清洁工，用于取消订阅，或者清理资源，

// 创建信号
    RACSignal *signal = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
        //发送信号
        [subscriber sendNext:@"发送消息"];
        //发送信号完成
        [subscriber sendCompleted];
        return [RACDisposable disposableWithBlock:^{

            NSLog(@"信号被销毁")；
        }];
    }];

    // 只有订阅信号才能接收到数据
    [signal subscribeNext:^(id x) {
         NSLog(@"接收到数据:%@",x);
    }];

RACCommand:

事件的处理类,运用这个类可以监听到事件执行的整个过程

self.command = [[RACCommand alloc] initWithSignalBlock:^RACSignal * _Nonnull(id  _Nullable input) {
       //默认要创建一个信号，如果不做任何操作可以创建空信号
       // return  [RACSignal empty];

        //input这个参数是执行的时候传入的，根据这个参数可以看出RACCommand的运行过程
       return [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {

           //发送
           [subscriber sendNext:input];
           [subscriber sendCompleted];

           return nil;
       }];
    }];

    //订阅(信号中的信号)，switchToLatest:获取信号中的信号，有的时候信号也可以发出信号
    [[self.command.executionSignals switchToLatest] subscribeNext:^(id  _Nullable input) {
        NSLog(@"%@",input);
    }];

    //执行
    [self.command execute:@(1)];

RACSubject和RACReplaySubject:

RACSubject可以提供信号，自己也是信号的提供者，

RACReplaySubject是RACSubject子类，可以重复提供信号，可以先发送，再订阅，也可以多次订阅，但是RACSubjec由于过于灵活，官方也不建议使用。

RACSubject * subject = [RACSubject subject];

    //先订阅
    [subject subscribeNext:^(id  _Nullable x) {
        NSLog(@"%@",x);
    }];

    //一定要先订阅再发送
    [subject sendNext:@"1"];



    RACReplaySubject  *replaySubject = [RACReplaySubject subject];
    //可以先发送再订阅
    [replaySubject sendNext:@"1"];
    [replaySubject sendNext:@"2"];

    [replaySubject subscribeNext:^(id  _Nullable x) {
        //只要订阅了就会接受到发送的所有数据，所以订阅的block都会执行两次
        NSLog(@"%@",x);
    }];

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

4.基本用法

基本宏

1.RAC(TARGET, [KEYPATH, [NIL_VALUE]]) 绑定对象属性

2.RACObserve(self, name) 监听属性变化的信号

3.

//RACTuplePack:把数据包装成元祖
    RACTuple *tuple = RACTuplePack(@(111),@"222");

    //RACTuplePack:解包，把元祖解包成对应的数据类型
    RACTupleUnpack(NSNumber * number,NSString * string) = tuple;
    NSLog(@"%@--%@",number,string);

    //RACTuple提供了直接访问元素的属性
    NSNumber *tNumber = tuple.first;
    NSString *tString = tuple.second;
    NSLog(@"%@--%@",tNumber,tString);

替换传统消息机制

• rac_signalForSelector 替换代理
• rac_signalForControlEvents 替换UIControl Target-Action方法
• rac_valuesAndChangesForKeyPath 替换KVO
• rac_addObserverForName 替换通知
• rac_textSignal 替换文本监听代理

rac_signalForSelector替换代理有局限性，只能用于没有返回值的代理

使用基本方法

1.过滤

• filter

[[self.userNameTF.rac_textSignal
      filter:^BOOL(NSString * value){
          //用户登录的时候限制用户名的长度
          return value.length > 11;
      }]
     subscribeNext:^(id x){
         //过滤信号，符合条件订阅才会接收到
         NSLog(@"%@", x);
     }];

• distinctUntilChanged： 
  也有过滤的功能，当信号中上一次的值与当前的值又变化的时候，就会发出信号。
• take,takeLast，skip

RACSignal *signal = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        [subscriber sendNext:@"1"];
        [subscriber sendNext:@"2"];
        [subscriber sendNext:@"3"];
        [subscriber sendCompleted];
        return nil;
    }];
    [[signal take:2] subscribeNext:^(id  _Nullable x) {
        //订阅信号，“2”代表取前两次的信号，打印1，2
        NSLog(@"%@",x);
    }];

    [[signal takeLast:2] subscribeNext:^(id x) {
        //订阅信号，“2”代表取最后两次的信号，打印2，3
        NSLog(@"%@",x);
    }];


    [[signal skip:2] subscribeNext:^(id  _Nullable x) {
        //skip代表跳过信号，参数代表个数，跳过两个信号，打印3
        NSLog(@"%@",x);
    }];

2.映射（map&flatternMap）

//flattenMap和map的区别就是返回的是值还是信号
    [[self.userNameTF.rac_textSignal map:^id _Nullable(NSString * _Nullable value) {
        //用户登录限制长度也可以用映射，把用户输入的字符串的信号转化成是否可以登录的信号
        return @(value.length > 11);
    }] subscribeNext:^(NSNumber  *_Nullable isLogin) {
        NSLog(@"%d",[isLogin boolValue]);
    }];
    //当就要映射信号的时候用flattenMap
    [self.userNameTF.rac_textSignal flattenMap:^__kindof RACSignal * _Nullable(NSString * _Nullable value) {
       //需要返回信号
        return self.userNameTF.rac_textSignal;
    }];

3.合并

• concat拼接

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

    [[signle1 concat:signle2] subscribeNext:^(id  _Nullable x) {
        //concat拼接功能，把signle1拼到signle2之前，按照顺序执行，打印1，2，3，4
        NSLog(@"%@",x);
    }];

• merge&zip&combineLatest 组合

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

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

    [[signle1 merge:signle2] subscribeNext:^(id  _Nullable x) {
        //merge，合并信号，当signle1和signle2任意一个发送，都会接收到，有点类似concat
        NSLog(@"%@",x);
    }];

    [[signle1 zipWith:signle2] subscribeNext:^(RACTuple  *_Nullable tuple) {
        //zip压缩信号，并把值也合并成元祖，但也是一个一个合并，所以会走两遍，1，3  2，4
        NSLog(@"%@--%@",tuple.first,tuple.second);
    }];



    [[signle1 combineLatestWith:signle2] subscribeNext:^(RACTuple *  _Nullable tuple) {
        //combineLatestWith也是合并信号，跟zip有点像，但是sigle1总会拿到最新的值才与signle2合并,打印 2，3  2，4
        NSLog(@"%@--%@",tuple.first,tuple.second);
    }];

• then

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


    [[signle then:^RACSignal * _Nonnull{
        return [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
            [subscriber sendNext:@"3"];
            return nil;
        }];
    }] subscribeNext:^(id  _Nullable x) {
        //then会把之前的信号过滤掉，所以这里只会接收到第二个信号的值 3
        NSLog(@"%@",x);
    }];

    [signle subscribeNext:^(id  _Nullable x) {
        //第一个信号订阅了，所以顺序执行到这里才会打印1，2
        NSLog(@"%@",x);
    }];

• delay&interval

[[RACSignal interval:5 onScheduler:[RACScheduler currentScheduler]] subscribeNext:^(NSDate * _Nullable x) {
        //定时，每个一段时间会调用，会把当前时间回调回来
        NSLog(@"%@",x);
    }];

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

    [[signle delay:5] subscribeNext:^(id  _Nullable x) {
      //延迟订阅
        NSLog(@"%@",x);
    }