美文网首页ios事件传递
RAC高阶函数

RAC高阶函数

作者: silasjs | 来源:发表于2020-10-23 09:44 被阅读0次

RAC高阶函数

0. bind

  • bind方法使用步骤:
    1. 传入一个返回值RACStreamBindBlock的block。
    2. 描述一个RACStreamBindBlock类型的bindBlock作为block的返回值。
    3. 描述一个返回结果的信号，作为bindBlock的返回值。

RACStreamBindBlock是一个block的类型，返回值是信号，参数（value,stop），因此参数的block返回值也是一个block。
RACStreamBindBlock:
参数一(value):表示接收到信号的原始值，还没做处理
参数二(stop):用来控制绑定Block，如果stop = yes,那么就会结束绑定。
返回值：信号，做好处理，在通过这个信号返回出去，一般使用RACReturnSignal,需要手动导入头文件RACReturnSignal.h。

  • bind底层原理
    1. 源信号调用bind,会重新创建一个绑定信号。
    2. 当绑定信号被订阅，就会调用绑定信号中的didSubscribe，生成一个bindingBlock。
    3. 当源信号有内容发出，就会把内容传递到bindingBlock处理，调用bindingBlock(value,stop)
    4. 调用bindingBlock(value,stop)，会返回一个内容处理完成的信号（RACReturnSignal）。
    5. 订阅RACReturnSignal，就会拿到绑定信号的订阅者，把处理完成的信号内容发送出来。
[[self.tf.rac_textSignal bind:^RACSignalBindBlock _Nonnull{
    return ^RACSignal * (NSString * __nullable value, BOOL *stop) {
        if (value.length >= 11) {
            [self.tf resignFirstResponder];
            *stop = YES;
        }
        return [RACReturnSignal return:value];
    };
}] subscribeNext:^(id  _Nullable x) {
    NSLog(@"bind:%@", x);
}];

1. 信号映射

map

// 输入一个11位数的手机号，map中在前面添加+86，超过11位时next信号就订阅不到了。
[[self.tf.rac_textSignal map:^id _Nullable(NSString * _Nullable value) {
    return value.length <= 11 ? [NSString stringWithFormat:@"+86 %@", value] : nil;
}] subscribeNext:^(id  _Nullable x) {
    NSLog(@"map:%@", x);
}];

flattenMap

  • flattenMap底层实现:
    1. flattenMap内部调用bind方法实现的,flattenMap中block的返回值，会作为bind中bindBlock的返回值。
    2. 当订阅绑定信号，就会生成bindBlock。
    3. 当源信号发送内容，就会调用bindBlock(value, *stop)
    4. 调用bindBlock，内部就会调用flattenMap的block，flattenMap的block作用：就是把处理好的数据包装成信号。
    5. 返回的信号最终会作为bindBlock中的返回信号。
    6. 订阅bindBlock的返回信号，就会拿到绑定信号的订阅者，把处理完成的信号内容发送出来。
[[self.tf.rac_textSignal flattenMap:^__kindof RACSignal * _Nullable(NSString * _Nullable value) {
    // value为源信号的内容，处理完后包装成RACReturnSignal返回。
    NSString *mapValue = [NSString stringWithFormat:@"+86 %@", value];
    return value.length <= 11 ? [RACReturnSignal return:mapValue] : [RACSignal empty];
}] subscribeNext:^(id  _Nullable x) {
    NSLog(@"flattenMap:%@", x);
}];

2. 信号过滤

filter

[[self.tf.rac_textSignal filter:^BOOL(NSString * _Nullable value) {
    BOOL isStop = value.length > 11;
    if (isStop) {
        self.tf.text = [value substringToIndex:11];
    }
    return !isStop;
}] subscribeNext:^(NSString * _Nullable x) {
    NSLog(@"filter:%@", x);
}];

ignore

[[self.tf.rac_textSignal ignore:@"13123456789"] subscribeNext:^(NSString * _Nullable x) {
    NSLog(@"ignore:%@", x);
}];

distinctUntilChanged

  • 当上一次的值和当前的值有明显的变化就会发出信号，否则会被忽略掉。
  • 在开发中，刷新UI经常使用，只有两次数据不一样才需要刷新
[[[RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
    [subscriber sendNext:@"1"];
    [subscriber sendNext:@"2"];
    [subscriber sendNext:@"2"];
    [subscriber sendNext:@"2"];
    [subscriber sendNext:@"3"];
    return [RACDisposable disposableWithBlock:^{
        NSLog(@"game over");
    }];
}] distinctUntilChanged] subscribeNext:^(id  _Nullable x) {
    NSLog(@"订阅到：%@", x);
}];

输出：
订阅到：1
订阅到：2
订阅到：3
game over

3. 信号合并

combineLatest

  • 将多个信号合并起来，并且拿到各个信号的最新的值,必须每个合并的signal至少都有过一次sendNext，才会触发合并的信号。

区别于zipWith，zipWith两个信号都要有记录,如果记录的信号触发过了就不再触发
zipWith：记录每一次信号
combineLatestWith：记录最后一次的信号

RACSignal *signalA = [self.tf rac_textSignal];
RACSignal *signalB = [self.btn rac_signalForControlEvents:UIControlEventTouchUpInside];
RACSignal *combineSignal = [signalA combineLatestWith:signalB];
[combineSignal subscribeNext:^(id  _Nullable x) {
    NSLog(@"combine:%@", x);
}];
  • 底层实现：
    1. 当组合信号被订阅，内部会自动订阅signalA，signalB,必须两个信号都发出内容，才会被触发。
    2. 并且把两个信号组合成元组发出。

reduce

  • 聚合：用于信号发出的内容是元组，把信号发出元组的值聚合成一个值。

其中Aggregation(聚合关系)、Composition(合成关系)属于Association(关联关系)，是特殊的Association关联关系。
可以延伸组合关系，聚合关系。
组合关系：A-B组合成了C C包含所有的A和B
聚合关系：聚合关系是整体和个体的关系(是强的关联关系) 公司与个人,但是个人不完全属于公司

  • 聚合，常见的用法，（先组合在聚合）。
  • combineLatest:(id<NSFastEnumeration>)signals reduce:(id (^)())reduceBlock
  • reduce中的block简介:
    • reduceblcok中的参数，有多少信号组合，reduceblcok就有多少参数，每个参数就是之前信号发出的内容
    • reduceblcok的返回值：聚合信号之后的内容。
RACSignal *signalA = [self.tf rac_textSignal];
RACSignal *sigbalB = [self.btn rac_signalForControlEvents:UIControlEventTouchUpInside];
[[RACSignal combineLatest:@[sigbalB, signalA] reduce:^id _Nonnull(id v1, id v2){
    return [NSString stringWithFormat:@"reduce = %@-%@", v1, v2];
}] subscribeNext:^(id  _Nullable x) {
    NSLog(@"订阅到：%@", x);
}];

merge

把多个信号合并成一个信号，任何一个信号发出，都可以订阅到。

RACSignal *signalA = [self.tf rac_textSignal];
RACSignal *sigbalB = [self.btn rac_signalForControlEvents:UIControlEventTouchUpInside];
[[signalA merge:sigbalB] subscribeNext:^(id  _Nullable x) {
    NSLog(@"merge:%@", x);
}];

zip

  • 合并信号，任何一个信号发送数据，都能监听到。
  • 底层实现:
    1. 定义压缩信号，内部就会自动订阅signalA，signalB
    2. 每当signalA或者signalB发出信号，就会判断signalA，signalB有没有发出个信号，有就会把最近发出的信号都包装成元组发出。
RACSignal *signalA = [self.tf rac_textSignal];
RACSignal *sigbalB = [self.btn rac_signalForControlEvents:UIControlEventTouchUpInside];
[[signalA zipWith:sigbalB] subscribeNext:^(id  _Nullable x) {
    NSLog(@"zip:%@", x);
}];

4. 信号连接

concat

信号相连，依次订阅到。要注意：前面的信号必须发送完成，才能接力到下一个信号。

RACSignal *signalA = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
    [subscriber sendNext:@"one"];
    // [subscriber sendError:nil];
    // 前面的信号必须发送完成，才能接力到下一个信号。
    [subscriber sendCompleted];
    return [RACDisposable disposableWithBlock:^{
        NSLog(@"signalA dispose");
    }];
}];
RACSignal *signalB = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
    [subscriber sendNext:@"two"];
    return [RACDisposable disposableWithBlock:^{
        NSLog(@"signalB dispose");
    }];
}];
[[signalA concat:signalB] subscribeNext:^(id  _Nullable x) {
    NSLog(@"concat:%@", x);
}];

then

信号相连，只订阅到最后一个。要注意：前面的信号必须发送完成，才能接力到下一个信号。

[[[RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
    [subscriber sendNext:@"one"];
    // [subscriber sendError:nil];
    // 前面的信号必须发送完成，才能接力到下一个信号。
    [subscriber sendCompleted];
    return [RACDisposable disposableWithBlock:^{
        NSLog(@"signalA dispose");
    }];
}] then:^RACSignal * _Nonnull{
    return [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        [subscriber sendNext:@"two"];
        return [RACDisposable disposableWithBlock:^{
            NSLog(@"signalB dispose");
        }];
    }];
}] subscribeNext:^(id  _Nullable x) {
    NSLog(@"then:%@", x);
}];

5. 信号操作时间

timeout

NSLog(@"%s", __func__);
[[[RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
    return [RACDisposable disposableWithBlock:^{
        NSLog(@"signal dispose");
    }];
}] timeout:5 onScheduler:[RACScheduler currentScheduler]] subscribeNext:^(id  _Nullable x) {
    NSLog(@"timeOut:%@", x);
} error:^(NSError * _Nullable error) {
    NSLog(@"timeOut-error:%@", error);
}];

输出：
20:09:29 -[ViewController testTimeOut]
20:09:29 signal dispose
20:09:34 timeOut-error:Error Domain=RACSignalErrorDomain Code=1 "(null)"

interval

[[RACSignal interval:1 onScheduler:[RACScheduler currentScheduler]] subscribeNext:^(NSDate * _Nullable x) {
    NSLog(@"interval:%@",[NSThread currentThread]);
}];

dely

[[[RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
    [subscriber sendNext:@"1"];
    return [RACDisposable disposableWithBlock:^{
        NSLog(@"signal dispose");
    }];
}] delay:3] subscribeNext:^(id  _Nullable x) {
    NSLog(@"dely:%@", x);
}];

6. 信号取值

take

屏蔽一些信号，取前 N 个信号。

[[[RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
    [subscriber sendNext:@"1"];
    [subscriber sendNext:@2];
    [subscriber sendNext:@3];
    return [RACDisposable disposableWithBlock:^{
        NSLog(@"signal dispose");
    }];
}] take:2] subscribeNext:^(id  _Nullable x) {
    NSLog(@"take:%@", x);
}];

tekeLast

屏蔽一些信号，取后 N 个信号。注意：必须发送完成信号，才能确定最后的 N 个信号。

[[[RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
    [subscriber sendNext:@"1"];
    [subscriber sendNext:@2];
    [subscriber sendNext:@3];
    // 必须发送完成信号，才能确定最后的 N 个信号。
    [subscriber sendCompleted];
    return [RACDisposable disposableWithBlock:^{
        NSLog(@"signal dispose");
    }];
}] takeLast:2] subscribeNext:^(id  _Nullable x) {
    NSLog(@"takeLast:%@", x);
}];

takeUntil

[A takeUntil:B]：B发出信号或者发出完成信号后，A的信号也就订阅不到了。

RACSubject *subjectA = [RACSubject subject];
RACSubject *subjectB = [RACSubject subject];
[[subjectA takeUntil:subjectB] subscribeNext:^(id  _Nullable x) {
    NSLog(@"takeUntil:%@", x);
}];
[subjectA sendNext:@"a-1"];
[subjectA sendNext:@"a-2"];
// [subjectB sendNext:@"b-2"];
[subjectA sendNext:@"a-3"];

[subjectA sendNext:@"a-4"];
[subjectB sendNext:@"b-1"];
[subjectA sendNext:@"a-5"];

7. 信号跳跃

skip

跳过前 N 个信号。

[[self.tf.rac_textSignal skip:3] subscribeNext:^(NSString * _Nullable x) {
    NSLog(@"skip:%@", x);
}];

8. 信号发送顺序

doNext

在源信号发送之前，可以在doNextBlock中做一些附加操作。

RACSignal *signalB = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
    [subscriber sendNext:@"signalB-1"];
    [subscriber sendNext:@"signalB-2"];
    [subscriber sendNext:@"signalB-3"];
    return [RACDisposable disposableWithBlock:^{
        NSLog(@"signalB dispose");
    }];
}];
[[signalB doNext:^(id  _Nullable x) {
    NSLog(@"do:%@", x);
}] subscribeNext:^(id  _Nullable x) {
    NSLog(@"订阅:%@", x);
}];

cocompleted

在源信号发送完成之前，可以在doCompletedBlock中做一些附加操作。

RACSignal *signalB = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
    [subscriber sendNext:@"signalB-1"];
    [subscriber sendNext:@"signalB-2"];
    [subscriber sendCompleted];
    [subscriber sendNext:@"signalB-3"];
    return [RACDisposable disposableWithBlock:^{
        NSLog(@"signalB dispose");
    }];
}];
[[signalB doCompleted:^{
    NSLog(@"do someting befor completed");
}] subscribeNext:^(id  _Nullable x) {
    NSLog(@"订阅到:%@", x);
}];

9. 获取信号中的信号

switchToLatest

获取信号中信号最近发出信号，订阅最近发出的信号。

RACSubject *signal = [RACSubject subject];
RACSubject *signalOfSignals = [RACSubject subject];
[[signalOfSignals switchToLatest] subscribeNext:^(id  _Nullable x) {
    NSLog(@"switchToLatest:%@", x);
}];
// 注意switchToLatest：只能用于信号中的信号
[signalOfSignals sendNext:signal];
[signal sendNext:@"i am a signal"];

10. 信号错误重试

retry

发送失败就会重新执行创建信号时的block，直至成功发送。

static int i = 0;
[[[RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
    if (i == 5) {
        [subscriber sendNext:[NSString stringWithFormat:@"%d", i]];
    } else {
        [subscriber sendError:nil];
    }
    i++;
    return [RACDisposable disposableWithBlock:^{
        NSLog(@"signal dispose");
    }];
}] retry] subscribeNext:^(id  _Nullable x) {
    NSLog(@"next:%@", x);
} error:^(NSError * _Nullable error) {
    NSLog(@"error:%@", error);
}];

replay

被 N 次订阅，则发送 N 遍信号。

RACSignal *signalA = [[RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
    [subscriber sendNext:@"signalA-1"];
    [subscriber sendNext:@"signalA-2"];
    [subscriber sendNext:@"signalA-3"];
    return [RACDisposable disposableWithBlock:^{
        NSLog(@"signalA dispose");
    }];
}] replay];
[signalA subscribeNext:^(id  _Nullable x) {
    NSLog(@"replay-1:%@", x);
}];
[signalA subscribeNext:^(id  _Nullable x) {
    NSLog(@"replay-2:%@", x);
}];

相关文章

网友评论

    本文标题：RAC高阶函数

    本文链接：https://www.haomeiwen.com/subject/ptjpgctx.html

    延伸阅读

    深度阅读

    • 您也可以注册成为美文阅读网的作者，发表您的原创作品、分享您的心情！

    栏目导航

    热点阅读

    ios事件传递

    关于我们|服务条款|联系我们|RAC高阶函数|投稿指南|网站地图|RSS订阅|排版工具|手机版

    提供经典美文摘抄,优美散文欣赏,现代诗歌精选,短篇小说,心情随笔,表白情书范文,故事会在线阅读欣赏

    Copyright © 2014-2023 Haomeiwen.com All Rights Reserved. 好美文阅读网 版权所有

    备案信息：桂公网安备 45052102000051号 · 桂ICP备13007215号-3

    本站所收录作品、热点评论等信息部分来源互联网，目的只是为了系统归纳学习和传递资讯

    所有作品版权归原创作者所有，与本站立场无关，如不慎侵犯了你的权益，请联系我们告知，我们将做删除处理！