011.理解事件(events)和流(streams)

在软件系统中,事件是一种用于指示发生了什么事情的消息。该事件可能代表一个技术事件——例如,在GUI应用程序中,您可能会在按下的每个键或每次鼠标移动上看到事件。该事件还可以表示业务发生,例如在金融系统中完成的货币交易。

事件由事件源引发,并由事件处理程序使用。正如您所看到的,事件是表示时变值的一种方式。在Rx中,事件源可以由可观察的表示,事件处理程序可以由观察者表示。但是,我们的应用程序正在使用的简单数据呢,比如数据库中的数据或从web服务器获取的数据。它在被动世界中有一席之地吗?

一、一切都是“流”
您编写的应用程序最终将处理某种数据,如图1.15所示。数据可以有两种类型:静止数据和运动数据。
在这里插入图片描述
图1.15运动数据和静止数据作为一个数据流。来自外部环境的连接点非常适合创建可观察性。这些可观测值可以很容易地与Rx合并,以创建合并的可观测值,内部模块可以在不知道数据元素的确切来源的情况下订阅该可观测值。

静态数据以数字格式存储,通常从数据库或文件等持久存储中读取。运动中的数据在网络(或其他介质)上移动,并被推送到您的应用程序或由您的应用从任何外部源提取。

无论您在应用程序中使用何种类型的数据,都应该明白,一切都可以作为流来观察,甚至是静止的数据和对应用程序来说看起来静态的数据。例如,配置数据被认为是静态的,但即使在某个时刻,配置也会发生变化,无论是在长时间还是短时间之后。从应用程序的角度来看,这并不重要;你想被动应对,并在这些变化发生时处理它们。当您将静止的数据视为另一个数据流时,可以更容易地组合这两种类型的数据。对于您的应用程序来说,数据来自何处并不重要。

例如,应用程序启动通常从其持久存储加载数据以恢复其状态(应用程序关闭前保存的状态)。当然,在应用程序运行过程中,这种状态可能会发生变化。应用程序的内部关心状态的部分可以查看承载它的数据流。当应用程序启动时,流将传递加载的数据,当状态发生变化时,流会承载更新。

我喜欢用一个很好的比喻来解释流,那就是水管,但这个水管有数据包穿过它,就像你在图1.16中看到的那样。当使用水管时,你可以用它做很多事情。你可以在末端安装过滤器。可以添加不同的软管头,以提供不同的功能。您可以添加压力监测器来帮助调节流量。您可以对数据流执行同样的操作。你会想要建立一个管道,让信息在其中流动,最终给出适合你逻辑的最终结果;这包括过滤、转换、分组、合并等等。

数据流和事件流非常适合Rx可观察性。使用IObservable对它们进行抽象使您能够合成运算符并创建复杂的执行管道。这与您对Shoppy示例所做的类似,在Shoppy示例中,对服务器的调用作为更复杂的执行管道的一部分获得了折扣,该管道还使用了过滤(在连接上)并最终刷新了视图(就像洒水喷头泼水一样)。

在这里插入图片描述
图1.16数据流就像一根软管:每一滴水都是一个数据包,需要经过各个站点,直到到达终点。您的数据还需要进行过滤和转换,直到它到达真正的处理程序,并对其进行有用的处理。

——未完待续

译者:重庆教主(QQ23611316) 2024.05.14

网站:WPF中文网 wpfsoft.com

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:/a/627211.html

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

【启程Golang之旅】环境设置、工具安装与代码实践

欢迎来到Golang的世界!在当今快节奏的软件开发领域,选择一种高效、简洁的编程语言至关重要。而在这方面,Golang(又称Go)无疑是一个备受瞩目的选择。在本文中,带领您探索Golang的世界,一步步地了…

LearnOpenGL(十七)之混合

一、丢弃片段 有些图片并不需要半透明,只需要根据纹理颜色值,显示一部分(alpha值为1.0),或者不显示一部分(alpha值为0.0),没有中间情况。我们需要丢弃(Discard)显示纹理中透明部分的…

嵌入式学习71-(内核定时器和传感器)

缺少内核配置文件.config 解决:cp config_mini2440_td35 .config 1.make 编译一下 生成timer.ko文件 2. cp timer.ko ~/nfs/rootfs 为什么要拷贝到rootfs中,这是挂载的根文件系统 ,使用nfs作为根文件系统 实际上内核启动的时候并不知道…

【问题实操】银河高级服务器操作系统实例分享,网卡drop问题分析

1.服务器环境以及配置 系统环境 物理机/虚拟机/云/容器 物理机 网络环境 外网/私有网络/无网络 私有网络 硬件环境 机型 华鲲振宇 TG225B1 处理器 kunpeng 920 内存 1024GB 主板型号 TG225B1 HZKY 整机类型/架构 aarch64 固件版本 6.57 软件环境 具体操作系…

基于梯度流的扩散映射卡尔曼滤波算法的信号预处理matlab仿真

目录 1.程序功能描述 2.测试软件版本以及运行结果展示 3.核心程序 4.本算法原理 4.1 扩散映射(Diffusion Maps) 4.2 卡尔曼滤波 4.3 基于梯度流的扩散映射卡尔曼滤波(GFDMKF) 5.完整程序 1.程序功能描述 基于梯度流的扩散…

Golang | Leetcode Golang题解之第89题格雷编码

题目&#xff1a; 题解&#xff1a; func grayCode(n int) []int {ans : make([]int, 1<<n)for i : range ans {ans[i] i>>1 ^ i}return ans }

vue3使用el-radio-group获取表格数据无法选中问题

这里是引用 今天写项目发现使用el-radio-group无法获取表格中的数据&#xff0c;于是去官网查看了一下&#xff0c;发现写的没啥问题&#xff0c;就是 <el-radio value"1" size"large"> 未知</el-radio>这样的写法&#xff0c;又在网上看了一些…

RGMII基于V2.0规范解读

一、说明 RGMII&#xff08;Reduced Gigabit Media Independent Interface&#xff09;是Reduced GMII&#xff08;吉比特介质独立接口&#xff09;&#xff0c;旨在替代IEEE802.3u MII、IEEE802.3z GMII和TBI。主要目标是将MAC和PHY互连所需的引脚数量从最大28个引脚&#xf…

求正方形阴影部分面积

正方形边长6&#xff0c;求阴影部分面积 xy6① vw6② 1/26v1/23x1/263③ 1/26v1/26y1/266④ ③是左下角三角形的面积&#xff0c;④是左上角三角形的面积。 求解方程组得到x2 阴影部分面积1/2*3x3.

第2章Spring Boot实践,开发社区登录模块【仿牛客网社区论坛项目】

第2章Spring Boot实践&#xff0c;开发社区登录模块【仿牛客网社区论坛项目】 前言推荐项目总结第2章Spring Boot实践&#xff0c;开发社区登录模块1.发送邮件配置MailClient测试 2.开发注册功能访问注册页面提交注册数据激活注册账号 3.会话管理体验cookie体验session 4.生成验…

idea使用gitee基本操作流程

1.首先&#xff0c;每次要写代码前&#xff0c;先切换到自己负责的分支 点击签出。 然后拉取一次远程master分支&#xff0c;保证得到的是最新的代码。 写完代码后&#xff0c;在左侧栏有提交按钮。 点击后&#xff0c;选择更新的文件&#xff0c;输入描述内容&#xff08;必填…

数据结构--链表的基本操作

1. 链表的概念及结构 概念&#xff1a;链表是⼀种物理存储结构上⾮连续、⾮顺序的存储结构&#xff0c;数据元素的逻辑顺序是通过链表 中的指针链接次序实现的 。 链表也是线性表的一种。 链表的结构跟⽕⻋⻋厢相似&#xff0c;淡季时⻋次的⻋厢会相应减少&#xff0c;旺季时…

Java(四)---方法的使用

文章目录 前言1.方法的概念和使用2.方法的定义3.实参和形参的关系4.方法重载4.1.改进4.2.注意事项 5.递归5.1 生活中的故事5.2 递归的概念 5.3.练习 前言 前面一章我们学习到了程序逻辑语句&#xff0c;在写代码的过程中&#xff0c;我们会遇到需要重复使用的代码块&#xff0…

运维别卷系列 - 云原生监控平台 之 05.prometheus alertManager 实践

文章目录 [toc]Alertmanager 简介Alertmanager 实现的核心概念GroupingInhibitionSilencesClient behaviorHigh Availability Alertmanager 配置文件globaltemplatesrouteinhibit_rulesreceivers Alertmanager 部署创建 cm创建 svc创建 stsPrometheus 配置告警Prometheus 配置文…

React Native 开发心得分享

有一段时间没更新了&#xff0c;花了点时间研究了下 React Native&#xff08;后续用 RN 简称&#xff09;&#xff0c;同时也用该技术作为我的毕设项目(一个校园社交应用&#xff0c;仿小红书)&#xff0c;经过了这段时间的疯狂折腾&#xff0c;对 RN 生态有了一定的了解&…

3.TCP的三次握手和四次挥手

一、前置知识 TCP是一种面向连接的、可靠的、基于字节流的传输层通信协议。在传输数据前通信双方必须建立连接&#xff08;所谓连接&#xff0c;是指客户端和服务端各自保存一份关于对方的信息&#xff0c;比如ip地址&#xff0c;端口号等&#xff09;。TCP通过三次握手建立一个…

iOS 创建pch文件

1.参考链接&#xff08;xcode8添加方法&#xff0c;之前的跟这个差不多&#xff09;&#xff1a; 参考链接 2.自我总结&#xff1a; &#xff08;1&#xff09;创建pch文件: 注意点&#xff1a;1&#xff09;注意选中所有的targets&#xff08;看图明义&#xff09; 2&…

风电功率预测 | 基于CNN卷积神经网络的风电功率预测(附matlab完整源码)

风电功率预测 风电功率预测完整代码风电功率预测 基于卷积神经网络(Convolutional Neural Network, CNN)的风电功率预测可以通过以下步骤实现: 数据准备:收集与风电场发电功率相关的数据,包括风速、风向、温度、湿度等气象数据以及风电场的历史功率数据。 数据预处理:对…

ACM8628 2×41W立体声1×82W单通道数字功放中文寄存器表

ACM8628M是一款国产高度集成、高效率的双通道数字输入功放。供电电压范围在4.5V-26.4V,数字接口电源支持3.3V或1.8V。在8欧负载下&#xff0c;输出功率可以到241W&#xff0c;PBTL模式下单通道可以输出182W1% THDN. 器件介绍见 内置DSP多种音频处理效果ACM8628M-241W立体声…

「51媒体」家居生活发布会,展览展会有哪些媒体邀约资源

传媒如春雨&#xff0c;润物细无声&#xff0c;大家好&#xff0c;我是51媒体网胡老师。 家居生活类媒体包括多种类型&#xff0c;包括门户网站家居生活消费频道&#xff0c;专业的家居消费生活门户&#xff0c;以及行业媒体&#xff0c;平面媒体&#xff0c;KOL和意见领袖。下…