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

2023-12-14 14:38

本文主要是介绍ReactiveCocoa框架菜鸟入门(四)——信号(Signal)详解,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

基础知识

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

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

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

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

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

处理逻辑
数据内容
处理逻辑指的是创建信号的时候,它是如何通知订阅者(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 the original signal. 
* 5. When all signals 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方法最重要的特点之一。
同样需要注意的是方法的第一行代码:

RACStreamBindBlock bindingBlock = block();

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

id signal = bindingBlock(x, &stop);

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

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

FlattenMap

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

观察FlattenMap方法的实现代码

- (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方法。

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

转载网址: http://blog.csdn.net/abc649395594/article/details/46233783

这篇关于ReactiveCocoa框架菜鸟入门(四)——信号(Signal)详解的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/492913

相关文章

Spring Security基于数据库验证流程详解

Spring Security 校验流程图 相关解释说明(认真看哦) AbstractAuthenticationProcessingFilter 抽象类 /*** 调用 #requiresAuthentication(HttpServletRequest, HttpServletResponse) 决定是否需要进行验证操作。* 如果需要验证,则会调用 #attemptAuthentica

Spring Security 从入门到进阶系列教程

Spring Security 入门系列 《保护 Web 应用的安全》 《Spring-Security-入门(一):登录与退出》 《Spring-Security-入门(二):基于数据库验证》 《Spring-Security-入门(三):密码加密》 《Spring-Security-入门(四):自定义-Filter》 《Spring-Security-入门(五):在 Sprin

OpenHarmony鸿蒙开发( Beta5.0)无感配网详解

1、简介 无感配网是指在设备联网过程中无需输入热点相关账号信息,即可快速实现设备配网,是一种兼顾高效性、可靠性和安全性的配网方式。 2、配网原理 2.1 通信原理 手机和智能设备之间的信息传递,利用特有的NAN协议实现。利用手机和智能设备之间的WiFi 感知订阅、发布能力,实现了数字管家应用和设备之间的发现。在完成设备间的认证和响应后,即可发送相关配网数据。同时还支持与常规Sof

数论入门整理(updating)

一、gcd lcm 基础中的基础,一般用来处理计算第一步什么的,分数化简之类。 LL gcd(LL a, LL b) { return b ? gcd(b, a % b) : a; } <pre name="code" class="cpp">LL lcm(LL a, LL b){LL c = gcd(a, b);return a / c * b;} 例题:

6.1.数据结构-c/c++堆详解下篇(堆排序,TopK问题)

上篇:6.1.数据结构-c/c++模拟实现堆上篇(向下,上调整算法,建堆,增删数据)-CSDN博客 本章重点 1.使用堆来完成堆排序 2.使用堆解决TopK问题 目录 一.堆排序 1.1 思路 1.2 代码 1.3 简单测试 二.TopK问题 2.1 思路(求最小): 2.2 C语言代码(手写堆) 2.3 C++代码(使用优先级队列 priority_queue)

Java 创建图形用户界面(GUI)入门指南(Swing库 JFrame 类)概述

概述 基本概念 Java Swing 的架构 Java Swing 是一个为 Java 设计的 GUI 工具包,是 JAVA 基础类的一部分,基于 Java AWT 构建,提供了一系列轻量级、可定制的图形用户界面(GUI)组件。 与 AWT 相比,Swing 提供了许多比 AWT 更好的屏幕显示元素,更加灵活和可定制,具有更好的跨平台性能。 组件和容器 Java Swing 提供了许多

【IPV6从入门到起飞】5-1 IPV6+Home Assistant(搭建基本环境)

【IPV6从入门到起飞】5-1 IPV6+Home Assistant #搭建基本环境 1 背景2 docker下载 hass3 创建容器4 浏览器访问 hass5 手机APP远程访问hass6 更多玩法 1 背景 既然电脑可以IPV6入站,手机流量可以访问IPV6网络的服务,为什么不在电脑搭建Home Assistant(hass),来控制你的设备呢?@智能家居 @万物互联

poj 2104 and hdu 2665 划分树模板入门题

题意: 给一个数组n(1e5)个数,给一个范围(fr, to, k),求这个范围中第k大的数。 解析: 划分树入门。 bing神的模板。 坑爹的地方是把-l 看成了-1........ 一直re。 代码: poj 2104: #include <iostream>#include <cstdio>#include <cstdlib>#include <al

cross-plateform 跨平台应用程序-03-如果只选择一个框架,应该选择哪一个?

跨平台系列 cross-plateform 跨平台应用程序-01-概览 cross-plateform 跨平台应用程序-02-有哪些主流技术栈? cross-plateform 跨平台应用程序-03-如果只选择一个框架,应该选择哪一个? cross-plateform 跨平台应用程序-04-React Native 介绍 cross-plateform 跨平台应用程序-05-Flutte

K8S(Kubernetes)开源的容器编排平台安装步骤详解

K8S(Kubernetes)是一个开源的容器编排平台,用于自动化部署、扩展和管理容器化应用程序。以下是K8S容器编排平台的安装步骤、使用方式及特点的概述: 安装步骤: 安装Docker:K8S需要基于Docker来运行容器化应用程序。首先要在所有节点上安装Docker引擎。 安装Kubernetes Master:在集群中选择一台主机作为Master节点,安装K8S的控制平面组件,如AP