ReactiveCocoa比较区分replay, replayLast和replayLazily

原文地址；https://spin.atomicobject.com/2014/06/29/replay-replaylast-replaylazily/

Subscribing to a Signal

　　对于一个“普通”的信号，每次订阅都将会导致信号中的代码再执行一遍，且该次订阅者仅接收到该次订阅发送出去的值。

　　第一个例子演示每次订阅都会重新执行订阅代码。

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24

__block int num = 0; RACSignal * signal = [RACSignal createSignal:^RACdisposable *(id subscriber) { num++; NSLog(@ "Increment num to: %i" ,num); [subscriber sendNext:@(num)]; return nil; }]; "Start subscriptions" ); // Subscriber 1 (S1) [ subscribeNext:^(id x) { "S1: %@" ottom:auto!important; float:none!important; height:auto!important; left:auto!important; line-height:1.1em!important; margin:0px!important; outline:0px!important; overflow:visible!important; padding:0px!important; position:static!important; right:auto!important; top:auto!important; vertical-align:baseline!important; width:auto!important; font-family:Consolas,x); }]; // Subscriber 2 (S2) subscribeNext:^(id x) { "S2: %@" ottom:auto!important; float:none!important; height:auto!important; left:auto!important; line-height:1.1em!important; margin:0px!important; outline:0px!important; overflow:visible!important; padding:0px!important; position:static!important; right:auto!important; top:auto!important; vertical-align:baseline!important; width:auto!important; font-family:Consolas,x); }]; // Subscriber 3 (S3) subscribeNext:^(id x) { "S3: %@" ottom:auto!important; float:none!important; height:auto!important; left:auto!important; line-height:1.1em!important; margin:0px!important; outline:0px!important; overflow:visible!important; padding:0px!important; position:static!important; right:auto!important; top:auto!important; vertical-align:baseline!important; width:auto!important; font-family:Consolas,x); }];

　　运行结果如下：

7

Start subscriptions Increment num to: 1 S1: 1 Increment num to: 2 S2: 2 Increment num to: 3 S3: 3

　　可以看到，每次订阅num都在递增，如果不订阅则不会递增。通过这种方式，可以知道信号是懒惰的，如果没有订阅者的话，是不会执行的。

　　第二个例子演示信号被添加订阅的时候，订阅者是怎么接收发送的值的。

24

25

26

27

RACSubject *letters = [RACSubject subject]; = letters; "Subscribe S1" ); subscribeNext:^(id x) { ottom:auto!important; float:none!important; height:auto!important; left:auto!important; line-height:1.1em!important; margin:0px!important; outline:0px!important; overflow:visible!important; padding:0px!important; position:static!important; right:auto!important; top:auto!important; vertical-align:baseline!important; width:auto!important; font-family:Consolas,x); }]; "Send A" [letters sendNext:@ "A" ]; "Send B" ); "B" ]; "Subscribe S2" ); subscribeNext:^(id x) { ottom:auto!important; float:none!important; height:auto!important; left:auto!important; line-height:1.1em!important; margin:0px!important; outline:0px!important; overflow:visible!important; padding:0px!important; position:static!important; right:auto!important; top:auto!important; vertical-align:baseline!important; width:auto!important; font-family:Consolas,x); }]; "Send C" ); "C" ]; "Send D" ); "D" ]; "Subscribe S3" ); subscribeNext:^(id x) { ottom:auto!important; float:none!important; height:auto!important; left:auto!important; line-height:1.1em!important; margin:0px!important; outline:0px!important; overflow:visible!important; padding:0px!important; position:static!important; right:auto!important; top:auto!important; vertical-align:baseline!important; width:auto!important; font-family:Consolas,x); 运行结果 19 Subscribe S1 Send A S1: A Send B S1: B Subscribe S2 Send C S1: C S2: C Send D S1: D S2: D Subscribe S3 　　在很多情况下，这是我们想要的预期结果，不过在某些情况下，你不需要订阅的代码再次被执行。例如订阅 一个向网络服务器发送的请求，当服务器返回数据时，多个监听者需要更新(无论有多少个监听者，请求只发送一下（第一个例子就不满足我们的需求）)，或者我们想拿到订阅前信号发送过的值（第二个例子，S2想拿A，B的值或者S3想拿A，B，C，D的值，就不满足我们的需求了）。因此-replay,-replayLast,and-replayLazily应需而生。 Subscribing to a -replay Signal 　　这个replay方法将返回一个新的信号，当源信号被订阅时，会立即发送给订阅者全部历史的值，不会重复执行源信号中的订阅代码，不仅如此，订阅者还将收到所有未来发送过去的值。 　　第一个例子演示信号添加新的订阅时，代码是不会再次被执行的。 = [[RACSignal createSignal:^RACdisposable *(id subscriber) { }] replay]; }]; 5 Increment num to: 1 Start subscriptions S2: 1 S3: 1 　　信号首次被订阅时，num立马被递增了，且仅仅递增了一次。这说明了不管有你多个订阅者，订阅代码我只执行了一次。 　　 　　第二个例子演示每个新添加的订阅者接收到信号中全部的值（不管是之前发出的值还是将来发出的值）。 　　 = [letters replay]; ]; subscribeNext:^(id x) { }]; ]; 25 Subscribe S1 Send A Subscribe S2 S2: A S2: B Send C S1: C S2: C Send D S1: D S2: D Subscribe S3 S3: A S3: B S3: C S3: D 　　尽管订阅者S3在所有的值发送之后再订阅，然后还能接收到所有的值。 Subscribing to a -replayLast Signal 　　这个replayLast返回一个新的信号，当源信号被订阅时，会立即发送给订阅者最新的值，不会重复执行源信号中的订阅代码。订阅者还会收到信号未来所有的值。 　　对于第一个例子，跟之前replay一样，所以我就不再次演示了。 　　第二个例子演示如何将最新的值提供给新的订阅者 = [letters replayLast]; 21 S2: B Send C S1: C S2: C Send D S1: D S2: D Subscribe S3 Subscribing to a -replayLazily Signal 　　这replayLazily方法返回一个新的信号，当源信号被订阅时，会立即发送给订阅者全部历史的值，不会重复执行源信号中的订阅代码。跟replay不同的是，replayLazily被订阅生成新的信号之前是不会对源信号进行订阅的（原文写的有点绕，简单来讲 直到订阅时候才真正创建一个信号，源信号的订阅代码才开始执行）。暂时不理解也没事，看下面的代码输出，和注释。 　这第一个例子会说明跟replay差异。 注意字符串“Increment num to: 1”是被订阅了之后才打印显示的。而replay和replayLast没被订阅前就打印了“Increment num to: 1” 这个消息。 }] replayLazily]; //跟replay不同的就这么一个地方 // 帖子滚动起来，跟replay比较一下 Increment num to: 1 的显示顺序。 Start subscriptions // 实际订阅 Increment num to: 1 // 信号开始创建 S1: 1 S2: 1 　　第二个例子演示将全部历史的值提供给任何新的订阅者，就像replay一样。 = [letters replayLazily]; 　　总结一下： 　　ReactiveCocoa提供了这三个简便的方法允许多个订阅者订阅一个信号，却不会重复执行订阅代码，并且能给新加的订阅者提供订阅前的值。replay和replayLast使信号变成热信号，且会提供所有值(-replay) 或者最新的值(-replayLast) 给订阅者。replayLazily返回一个冷的信号，会提供所有的值给订阅者。 版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 [e-mail] 举报，一经查实，本站将立刻删除。 相关推荐 react 学习11高阶组件 react 中的高阶组件主要是对于 hooks 之前的类组件来说的，如果组件之中有复用的代码，需要重新创建一个父类，父类中存储公共代码，返回子类，同时把公用属性... react 学习(四) 批量更新及合成事件 我们上一节了解了组件的更新机制，但是只是停留在表层上，例如我们的 setState 函数式同步执行的，我们的事件处理直接绑定在了 dom 元素上，这些都跟 re... react 学习(二) 实现类和函数式组件 我们上一节了解了 react 的虚拟 dom 的格式，如何把虚拟 dom 转为真实 dom 进行挂载。其实函数是组件和类组件也是在这个基础上包裹了一层，一个是调... react 学习12实现 cloneElement react 本身提供了克隆组件的方法，但是平时开发中可能很少使用，可能是不了解。我公司的项目就没有使用，但是在很多三方库中都有使用。本小节我们来学习下如果使用该... 实现简版 react 状态管理器 mobx mobx 是一个简单可扩展的状态管理库，中文官网链接。小编在接触 react 就一直使用 mobx 库，上手简单不复杂。 mini react-window(一) 实现固定高度虚拟滚动 我们在平常的开发中不可避免的会有很多列表渲染逻辑，在 pc 端可以使用分页进行渲染数限制，在移动端可以使用下拉加载更多。但是对于大量的列表渲染，特别像有实时数据... react 学习(六) 函数组件实例及类组件生命周期 本小节开始前，我们先答复下一个同学的问题。上一小节发布后，有小伙伴后台来信问到：‘小编你只讲了类组件中怎么使用 ref，那在函数式组件中怎么使用呢？’。确实我们... mini react-window(二) 实现可知变化高度虚拟列表 上一小节我们了解了固定高度的滚动列表实现，因为是固定高度所以容器总高度和每个元素的 size、offset 很容易得到，这种场景也适合我们常见的大部分场景，例如... react 学习(五) 完善 setState 及实现 ref 上一小节我们处理了 setState 的批量更新机制，但是我们有两个遗漏点，一个是源码中的 setState 可以传入函数，同时 setState 可以传入第二... react 学习13实现 PureComponent 我们知道 react 进行页面渲染或者刷新的时候，会从根节点到子节点全部执行一遍，即使子组件中没有状态的改变，也会执行。这就造成了性能不必要的浪费。之前我们了解... 小编推荐 苹果市值2025年有望达4万亿美元 • 网易云游戏怎么获得游戏时间？网易云游 • 腾讯课堂怎么评价课程？腾讯课堂评价课 • 微信转账如何隐藏实名？微信转账隐藏实 • 七天学堂如何注销账号？七天学堂重新登 • 哔哩哔哩游戏怎么设置视频静音播放？哔 • 高德地图如何创建群组?高德地图创建群组 • 钉钉自启动权限如何关闭?钉钉自启动权限 最新文章 • react 学习11高阶组件 • react 学习(四) 批量更新及合成事件 • react 学习(二) 实现类和函数式组件 • react 学习12实现 cloneElement • 实现简版 react 状态管理器 mobx • mini react-window(一) 实现固定高度虚… • react 学习(六) 函数组件实例及类组件生… • mini react-window(二) 实现可知变化高… • react 学习(五) 完善 setState 及实现 … • react 学习13实现 PureComponent 热门标签更多 友情链接: 前端之家 ai导航 编程之家 - 我要投稿 - 广告合作 - 联系我们 - 免责声明 - 网站地图 版权所有 © 2018编程之家闽ICP备13020303号-8 微信公众号搜"智元新知"关注 微信扫一扫可直接关注哦！