RxJava2 实战知识梳理(2) - 计算一段时间内数据的平均值
前言
今天,我们继续跟着 RxJava-Android-Samples 的脚步,一起看一下RxJava2
在实战当中的应用,在这个项目中,第二个的例子的描述如下:
简单地翻译过来:如果在2s
内连续点击了一个按钮五次,那么我们只会收到一个“你点击了该按钮五次”的时间,而不是五个"你点击了该按钮"的事件。这个示例的目的是让我们学会如何应用buffer
操作符。
示例
2.1 应用场景
仔细思考了一下,在平时的项目中,我们似乎不会遇到需要统计一段时间内用户点击了多少次按钮这种需求。
但是,我们有时候会需要计算一段时间内的平均数据,例如统计一段时间内的平均温度,或者统计一段时间内的平均位置。在接触RxJava
之前,我们一般会将这段时间内统计到的数据都暂时存起来,等到需要更新的时间点到了之后,再把这些数据结合起来,计算这些数据的平均值。
现在,我们就来看一下,用RxJava2
如何去实现这个需求。
2.2 示例代码
这里,我们通过一个Handler
循环地发送消息,实现间隔一定时间进行温度的测量,但是在测量之后,我们并不实时地更新界面的温度显示,而是每隔3s
统计一次过去这段时间内的平均温度。
实际的运行结果如下:
控制台输出的信息为:
示例解析
3.1 线程切换
在上面的例子中,我们使用了buffer(int time, Unit timeUnit)
,其原理图如下所示:
函数中的两个形参分别对应是时间的值和单位,这样,当我们通过下面这句发送事件:mPublishSubject.onNext(temperature);
事件并不会直接传递到Observer的onNext方法中,而是放在缓冲区中,直到事件到之后,再将所有在这段缓冲事件内放入缓冲区中的值,放在一个List中一起发送到下游。
3.2 Buffer 的其它用法
关于Buffer
的其它用法,这篇文章写得很全,我这里就不详细赘述了,大家可以参考:RxJava 的学习之变换操作符 - Buffer。
- java教程
- Java快速入门
- Java 开发环境配置
- Java基本语法
- Java 对象和类
- Java 基本数据类型
- Java 变量类型
- Java 修饰符
- Java 运算符
- Java 循环结构
- Java 分支结构
- Java Number类
- Java Character类
- Java String类
- Java StringBuffer和StringBuilder类
- Java 数组
- Java 日期时间
- Java 正则表达式
- Java 方法
- Java 流(Stream)、文件(File)和IO
- Java 异常处理
- Java 继承
- Java 重写(Override)与重载(Overload)
- Java 多态
- Java 抽象类
- Java 封装
- Java 接口
- Java 包(package)
- Java 数据结构
- Java 集合框架
- Java 泛型
- Java 序列化
- Java 网络编程
- Java 发送邮件
- Java 多线程编程
- Java Applet基础
- Java 文档注释
- R语言对回归模型进行协方差分析
- R语言多项式样条回归、非线性回归数据分析
- R语言中进行Spearman等级相关分析
- R语言相关分析和稳健线性回归分析
- R语言文本挖掘使用tf-idf描述NASA元数据的文字和关键字
- R语言对NASA元数据进行文本挖掘的主题建模分析
- 随机搜索变量选择SSVS估计贝叶斯向量自回归(BVAR)模型
- R语言VAR模型的不同类型的脉冲响应分析
- R语言用向量自回归(VAR)进行经济数据脉冲响应研究分析
- R语言从经济时间序列中用HP滤波器,小波滤波和经验模式分解等提取周期性成分分析
- python中使用scikit-learn和pandas决策树进行iris鸢尾花数据分类建模和交叉验证
- CNN+ Auto-Encoder 实现无监督Sentence Embedding ( 基于Tensorflow)
- R语言数据可视化分析案例:探索BRFSS数据
- R语言探索BRFSS数据可视化
- 基于ThinkPhp6.0+Vue 开发的一套免费开源新零售商城系统