ReactiveCocoa框架菜鸟入门四——信号Signal详解

http://demo.netfoucs.com/abc649395594/article/details/46233783

基础知识

在阅读本文之前,请确保你已成功导入ReactiveCocoa框架并对信号(Signal)和订阅者(Subscriber)有基本了解。或者尝试着完全理解以下一段内容:

信号是数据流,可以被绑定和传递。可以把信号想象成水龙头,只不过里面不是水,而是玻璃球(value),直径跟水管的内径一样,这样就能保证玻璃球是依次排列,不会出现并排的情况(数据都是线性处理的,不会出现并发情况)。水龙头的开关默认是关的,除非有了接收方(subscriber),才会打开。这样只要有新的玻璃球进来,就会自动传送给接收方。接收方就是放在水龙头下的盆子,对于水龙头不同的出水状况,有自己的处理方式。水龙头出水时会通知下方的水盆,如果没有水盆,水龙头始终处于关闭状态。

(转自linyawen的博客,附加了一些个人总结。)

再看信号

在前文中,以UITextfield的信号为例,示范了信号(Signal)的基本使用。但是,显然信号(Signal)的功能远不止这些。本文将详细介绍对信号进行的一系列操作。

首先,作为一个信号,我们关注它的两个方面:

  1. 处理逻辑
  2. 数据内容

处理逻辑指的是创建信号的时候,它是如何通知订阅者(Subscriber)并选择发送何种事件的。数据内容指的是信号会传递给订阅者(Subscriber)什么样的数据。这就像一个水龙头,它什么时候告诉水盆自己正在滴水,或是已经滴完水了。以及它把什么丢入水盆,是原始的水滴,还是水滴的质量?

如果我们需要对这些内容进行自定义的修改,那么修改原信号显然是不可行的(信号已经被创建了)。因此,这就牵涉到信号之间的转换(Map)与组合(Combine)。

我们从RACSignal类最基础的方法开始讨论信号之间的转换(Map)与组合(Combine)。对于每一个方法,我们需要关注这个方法的功能、返回值类型。由于ReactiveCocoa大量使用了block,还需要关注方法中block的参数类型和返回值类型。

绑定(Bind)

在RACSignal.m中找到bind方法。官方定义如下:

/*
* -bind: should:
*
* 1. Subscribe to the original signal of values.
* 2. Any time the original signal sends a value,transform it using the binding block.
* 3. If the binding block returns a signal,subscribe to it,and pass all of its values through to the subscriber as they’re received.
* 4. If the binding block asks the bind to terminate,complete theoriginalsignal.
* 5. Whenallsignals complete,send completed to the subscriber.
*
* If any signal sends an error at any point,send that to the subscriber.
*/

观察bind方法的实现(太长了,就不贴出来了)显然这个方法返回了一个新的信号。定义1表示会订阅原始信号,这样原始信号一定是热信号(Hot Signal)。定义4、5告诉我们新的信号发送事件和原始信号是同步的。这是bind方法最重要的特点之一。
同样需要注意的是方法的第一行代码:

 
 
  • 1
RACStreamBindBlock bindingBlock = block();

这里的block不再是此前我们简单认为的block。这个block被调用后,才得到一个block。这是一个block的嵌套。注意到后半段一行代码:

 
 
  • 1
id signal = bindingBlock(x,&stop);

这里表明,通过解封出来的block,产生一个新的signal。

因此,bind方法的作用大概已经清楚了:通过传入一个block(解除一层嵌套后)作用于原始信号上,产生一个新的信号。这个新的信号与原始信号保持同步。

FlattenMap

没办法翻译这个方法。但是它确实信号非常重要的一个方法。网上很多教程先介绍Map方法再把FlattenMap作为Map的补充介绍,这个逻辑是不正确的。观察源码不难发现,绑定(Bind)属于最底层操作,核心是保持了新旧信号的同步性和创造了对原始信号进行修改的可能。而FlattenMap初步提供了修改的机制。

观察FlattenMap方法的实现代码:

 
 
  • 1
- (instancetype)flattenMap:(RACStream * (^)(id value))block { Class class = self.class; return [[self bind:^{ return ^(id value,BOOL *stop) { id stream = block(value) ?: [class empty]; NSCAssert([stream isKindOfClass:RACStream.class],@"Value returned from -flattenMap: is not a stream: %@",stream); return stream; }; }] setNameWithFormat:@"[%@] -flattenMap:",self.name];}

最后的setNameWithFormat显然是一个格式化输出,并不影响信号的本质。直接无视它,那么这个方法的核心其实就是return [self bind:^{}];即返回了一个绑定了原始信号的新信号。bind方法的block中的return方法将在RACStreamBindBlock bindingBlock = block();时被调用,相当于解除了嵌套。实际上作用于原始信号的代码就是被return的那个block中的代码。

因此不难看出,FlattenMap方法的作用在于通过传入一个block,作用在原始信号传出的value上,得到一个新的信号。很抱歉我不明白一个blcok作用在value上能得到什么新的信号,但是实际使用中的情况是,这个value作为参数被传入blcok中,但是block完全没有用到这个参数,而是自己创建了一个信号。

相比于绑定(Bind)侧重于新信号和原始信号的同步性,FlattenMap方法实现了新 信号的修改。绑定(Bind)属于最底层操作,而FlattenMap方法是中间层,为实际应用提供了一个接口。当然有时候FlattenMap方法也会被我们直接调用。

信号(Signal)的各种操作

在之前的基础上,ReactiveCocoa提供了对信号的各种操作。这些操作几乎都用到了FlattenMap方法。意味着返回一个被修改之后的信号。同时,几乎每个操作还调用了return方法。

 
 
  • 1
//这个return不是我们用于返回一个值的return,只是名字比较像。+ (RACSignal *)return:(id)value { return [RACReturnSignal return:value];}

这个方法涉及到的代码比较多,就不一一细讲。该方法的主要作用是,返回一个新的信号,不过原始信号发送事件时的value将被新的value替换。
有了对绑定(Bind)方法、FlattenMap方法和return方法的理解,基本上就可以通过自己阅读源码搞定对信号(Signal)的各种操作了。这里列出几个常用的操作,如果依然不能理解,或者想要了解更多操作还是建议直接阅读源码。

filter
filter方法返回一个新的signal。原始信号的value被替换为了符合要求的value,从而实现了筛选、过滤的目的。是否符合要求是由传入的block决定的。即原来的信号的value,如果传入block中返回YES,则新的信号也将输出这个value。

map
map方法返回一个新的signal。原始信号的value被替换为了经过block处理的value。

distinctUntilChanged
distinctUntilChanged方法返回一个新的signal。这个signal只在value和前一个value不同的时候才会发送事件。简记为求异存同。

ignore
这个方法需要传入一个value,当信号收到一个value时,会检查是否和传入的value相同,如果相同就不会发送事件给订阅者。

skip&take
顾名思义,就是跳过(只发送)前n条数据。这里的n就是传入的参数值。

doNext
创建一个新的信号,这个信号和原始信号一模一样,不过可以在创建的过程中调用传入的block。

combineLatest:reduce
合并若干个信号,得到一个新的信号。把那些信号的value进行处理,得到一个处理过后的value作为新的信号的value。

throttle
throttle方法返回一个新的signal。只有在给定时间原始信号没有发送next事件,这个信号才会发送一个原始信号最近的一次next事件。

通过对信号的各种操作,我们把若干个水龙头连在一起,形成了一个水管。filter像是在两个水龙头之间加了一个过滤网,只有经过过滤网的水才能出现在下一个水龙头里。map像是在水龙头间加了一个转换器,前一个水龙头流出的水经过这个转换器就变成石油了。combineLatest:reduce则是把若干个水龙头的水一起引入一个新的水龙头……

以上是常用的信号(Signal)操作,更多的操作可以在源代码中找到,相信有了之前的基础,看懂这些代码并不困难。现在我们已经有了足够多的办法处理一个信号,开始实际编程工作已经不是问题了。

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。

相关推荐


react 中的高阶组件主要是对于 hooks 之前的类组件来说的,如果组件之中有复用的代码,需要重新创建一个父类,父类中存储公共代码,返回子类,同时把公用属性...
我们上一节了解了组件的更新机制,但是只是停留在表层上,例如我们的 setState 函数式同步执行的,我们的事件处理直接绑定在了 dom 元素上,这些都跟 re...
我们上一节了解了 react 的虚拟 dom 的格式,如何把虚拟 dom 转为真实 dom 进行挂载。其实函数是组件和类组件也是在这个基础上包裹了一层,一个是调...
react 本身提供了克隆组件的方法,但是平时开发中可能很少使用,可能是不了解。我公司的项目就没有使用,但是在很多三方库中都有使用。本小节我们来学习下如果使用该...
mobx 是一个简单可扩展的状态管理库,中文官网链接。小编在接触 react 就一直使用 mobx 库,上手简单不复杂。
我们在平常的开发中不可避免的会有很多列表渲染逻辑,在 pc 端可以使用分页进行渲染数限制,在移动端可以使用下拉加载更多。但是对于大量的列表渲染,特别像有实时数据...
本小节开始前,我们先答复下一个同学的问题。上一小节发布后,有小伙伴后台来信问到:‘小编你只讲了类组件中怎么使用 ref,那在函数式组件中怎么使用呢?’。确实我们...
上一小节我们了解了固定高度的滚动列表实现,因为是固定高度所以容器总高度和每个元素的 size、offset 很容易得到,这种场景也适合我们常见的大部分场景,例如...
上一小节我们处理了 setState 的批量更新机制,但是我们有两个遗漏点,一个是源码中的 setState 可以传入函数,同时 setState 可以传入第二...
我们知道 react 进行页面渲染或者刷新的时候,会从根节点到子节点全部执行一遍,即使子组件中没有状态的改变,也会执行。这就造成了性能不必要的浪费。之前我们了解...
在平时工作中的某些场景下,你可能想在整个组件树中传递数据,但却不想手动地通过 props 属性在每一层传递属性,contextAPI 应用而生。
楼主最近入职新单位了,恰好新单位使用的技术栈是 react,因为之前一直进行的是 vue2/vue3 和小程序开发,对于这些技术栈实现机制也有一些了解,最少面试...
我们上一节了了解了函数式组件和类组件的处理方式,本质就是处理基于 babel 处理后的 type 类型,最后还是要处理虚拟 dom。本小节我们学习下组件的更新机...
前面几节我们学习了解了 react 的渲染机制和生命周期,本节我们正式进入基本面试必考的核心地带 -- diff 算法,了解如何优化和复用 dom 操作的,还有...
我们在之前已经学习过 react 生命周期,但是在 16 版本中 will 类的生命周期进行了废除,虽然依然可以用,但是需要加上 UNSAFE 开头,表示是不安...
上一小节我们学习了 react 中类组件的优化方式,对于 hooks 为主流的函数式编程,react 也提供了优化方式 memo 方法,本小节我们来了解下它的用...
开源不易,感谢你的支持,❤ star me if you like concent ^_^
hel-micro,模块联邦sdk化,免构建、热更新、工具链无关的微模块方案 ,欢迎关注与了解
本文主题围绕concent的setup和react的五把钩子来展开,既然提到了setup就离不开composition api这个关键词,准确的说setup是由...
ReactsetState的执行是异步还是同步官方文档是这么说的setState()doesnotalwaysimmediatelyupdatethecomponent.Itmaybatchordefertheupdateuntillater.Thismakesreadingthis.staterightaftercallingsetState()apotentialpitfall.Instead,usecom