RxJava2 实战知识梳理(2) - 计算一段时间内数据的平均值
时间:2022-06-06
本文章向大家介绍RxJava2 实战知识梳理(2) - 计算一段时间内数据的平均值,主要内容包括其使用实例、应用技巧、基本知识点总结和需要注意事项,具有一定的参考价值,需要的朋友可以参考一下。
地址:http://www.jianshu.com/u/37baa8a86582
声明:本文是泽毛原创,已获其授权发布,未经原作者允许请勿转载
一、前言
今天,我们继续跟着 RxJava-Android-Samples 的脚步,一起看一下RxJava2
在实战当中的应用,在这个项目中,第二个的例子的描述如下:
简单地翻译过来:如果在2s
内连续点击了一个按钮五次,那么我们只会收到一个“你点击了该按钮五次”的时间,而不是五个"你点击了该按钮"的事件。这个示例的目的是让我们学会如何应用buffer
操作符。
二、事例
2.1 应用场景
仔细思考了一下,在平时的项目中,我们似乎不会遇到需要统计一段时间内用户点击了多少次按钮这种需求。但是,我们有时候会需要计算一段时间内的平均数据,例如统计一段时间内的平均温度,或者统计一段时间内的平均位置。在接触RxJava
之前,我们一般会将这段时间内统计到的数据都暂时存起来,等到需要更新的时间点到了之后,再把这些数据结合起来,计算这些数据的平均值。
现在,我们就来看一下,用RxJava2
如何去实现这个需求。
2.2 示例代码
这里,我们通过一个Handler
循环地发送消息,实现间隔一定时间进行温度的测量,但是在测量之后,我们并不实时地更新界面的温度显示,而是每隔3s
统计一次过去这段时间内的平均温度。
public class BufferActivity extends AppCompatActivity {
private PublishSubject<Double> mPublishSubject;
private CompositeDisposable mCompositeDisposable;
private TextView mTv;
private SourceHandler mSourceHandler;
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_buffer);
mTv = (TextView) findViewById(R.id.tv_buffer);
mPublishSubject = PublishSubject.create();
DisposableObserver<List<Double>> disposableObserver = new DisposableObserver<List<Double>>() {
@Override
public void onNext(List<Double> o) {
double result = 0;
if (o.size() > 0) {
for (Double d : o) {
result += d;
}
result = result / o.size();
}
Log.d("BufferActivity", "更新平均温度:" + result);
mTv.setText("过去3秒收到了" + o.size() + "个数据, 平均温度为:" + result);
}
@Override
public void onError(Throwable throwable) {
}
@Override
public void onComplete() {
}
};
mPublishSubject.buffer(3000, TimeUnit.MILLISECONDS).observeOn(AndroidSchedulers.mainThread()).subscribe(disposableObserver);
mCompositeDisposable = new CompositeDisposable();
mCompositeDisposable.add(disposableObserver);
mSourceHandler = new SourceHandler();
mSourceHandler.sendEmptyMessage(0);
}
public void updateTemperature(double temperature) {
Log.d("BufferActivity", "温度测量结果:" + temperature);
mPublishSubject.onNext(temperature);
}
private class SourceHandler extends Handler {
@Override
public void handleMessage(Message msg) {
super.handleMessage(msg);
double temperature = Math.random() * 25 + 5;
updateTemperature(temperature);
sendEmptyMessageDelayed(0, 250 + (long) (250 * Math.random()));
}
}
@Override
protected void onDestroy() {
super.onDestroy();
mSourceHandler.removeCallbacksAndMessages(null);
mCompositeDisposable.clear();
}
}
实际的运行结果为:
控制台输出的信息为:
三、事例解析
3.1 原理
在上面的例子中,我们使用了buffer(int time, Unit timeUnit)
,其原理图如下所示:
函数中的两个形参分别对应是时间的值和单位,这样,当我们通过下面这句发送事件:
mPublishSubject.onNext(temperature);
事件并不会直接传递到Observer
的onNext
方法中,而是放在缓冲区中,直到事件到之后,再将所有在这段缓冲事件内放入缓冲区中的值,放在一个List
中一起发送到下游。
3.2 Buffer 的其它用法
关于Buffer
的其它用法,这篇文章写得很全,我这里就不详细赘述了,大家可以参考:http://blog.csdn.net/hjjdehao/article/details/53079515
- 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 文档注释