深入浅出RxJava_04[数据传输过滤操作]
2017-02-27 21:24
295 查看
本教程基于RxJava1.x版本进行全面讲解,后续课程将陆续更新,敬请关注…
在被观察者发送数据给观察者的时候,在数据传输的时候,有可能需要对数据进一步过滤。以下的教程揽括了大部分过滤操作的函数。
Distinct - 去掉重复发送的数据
Filter - 根据条件过滤特定的数据
First - 取发送队列中的第一个数据
Last - 取发送队列中的最后一个数据
ElementAt - 根据索引发送队列中的特定数据
Take - 获取队列中的前n项数据
TakeLast - 获取队列中的后n项数据
Sample - 根据发送的数据通过发送时间采样发送
IgnoreElements - 忽略发送的数据队列
现在的需求就是,将重复名字的对象拦截掉。并打印出来:
输出如下:
下面的代码发送的数据是12345,定义过滤的规则是数据吧必须小于4,示例代码如下:
输出
示例代码
输出
类似的函数还有firstOrDefault(),该函数在队列发送的过程如果队列为null,也就是找不到第一项,则会发送一个默认值。
示例代码
输出
类似的函数还有lastOrDefault(T)
如果你传递的是一个负数,或者原始Observable的数据项数小于index+1,将会抛出一个IndexOutOfBoundsException异常。
示例代码如下:
输出
示例代码
输出
示例代码
输出
上面的代码打印:0,2,4,6,8。。。。
在被观察者发送数据给观察者的时候,在数据传输的时候,有可能需要对数据进一步过滤。以下的教程揽括了大部分过滤操作的函数。
Distinct - 去掉重复发送的数据
Filter - 根据条件过滤特定的数据
First - 取发送队列中的第一个数据
Last - 取发送队列中的最后一个数据
ElementAt - 根据索引发送队列中的特定数据
Take - 获取队列中的前n项数据
TakeLast - 获取队列中的后n项数据
Sample - 根据发送的数据通过发送时间采样发送
IgnoreElements - 忽略发送的数据队列
1.Distinct
现在有一个班级,学生的信息都已经录入到学生系统了。结果发现有相同的数据重复了。学生数据队列如下:private ArrayList<Student> initPersons() { ArrayList<Student> persons = new ArrayList<>(); persons.add(new Student("张三", 16)); persons.add(new Student("李四", 17)); persons.add(new Student("王二麻子", 18)); persons.add(new Student("张三", 22)); return persons; }
现在的需求就是,将重复名字的对象拦截掉。并打印出来:
Observable .from(initPersons()) //过滤重复名字的项 .distinct(new Func1<Student, String>() { @Override public String call(Student student) { return student.name; } }) .subscribe(new Action1<Student>() { @Override public void call(Student student) { Log.i(TAG, "call: "+student); } });
输出如下:
IT520: call: Student{name='张三', age=16} IT520: call: Student{name='李四', age=17} IT520: call: Student{name='王二麻子', age=18}
2.Filter
上面除了可以将传递数据的重复部分过滤掉,还可以通过filter根据规则清除特定的数据。下面的代码发送的数据是12345,定义过滤的规则是数据吧必须小于4,示例代码如下:
Observable.just(1, 2, 3, 4, 5) .filter(new Func1<Integer, Boolean>() { @Override public Boolean call(Integer item) { return( item < 4 ); } }) .subscribe(new Subscriber<Integer>() { @Override public void onNext(Integer item) { System.out.println("Next: " + item); } @Override public void onError(Throwable error) { System.err.println("Error: " + error.getMessage()); } @Override public void onCompleted() { System.out.println("Sequence complete."); } });
输出
Next: 1 Next: 2 Next: 3 Sequence complete.
3.First
调用了该函数可以让发送的数据队列只发送第一项。示例代码
Observable.just(1, 2, 3) .first() .subscribe(new Subscriber<Integer>() { @Override public void onNext(Integer item) { System.out.println("Next: " + item); } @Override public void onError(Throwable error) { System.err.println("Error: " + error.getMessage()); } @Override public void onCompleted() { System.out.println("Sequence complete."); } });
输出
Next: 1 Sequence complete.
类似的函数还有firstOrDefault(),该函数在队列发送的过程如果队列为null,也就是找不到第一项,则会发送一个默认值。
4.Last
调用了该函数可以让发送的数据队列只发送最后一项。示例代码
Observable.just(1, 2, 3) .last() .subscribe(new Subscriber<Integer>() { @Override public void onNext(Integer item) { System.out.println("Next: " + item); } @Override public void onError(Throwable error) { System.err.println("Error: " + error.getMessage()); } @Override public void onCompleted() { System.out.println("Sequence complete."); } });
输出
Next: 3 Sequence complete.
类似的函数还有lastOrDefault(T)
5.ElementAt
ElementAt操作符获取原始Observable发射的数据序列指定索引位置的数据项,然后当做自己的唯一数据发射。如果你传递的是一个负数,或者原始Observable的数据项数小于index+1,将会抛出一个IndexOutOfBoundsException异常。
示例代码如下:
Observable.just(1, 2, 3, 4, 1, 4) .elementAt(3) .subscribe(new Action1<Integer>() { @Override public void call(Integer value) { Log.i(TAG, "call: " + value); } });
输出
com.m520it.rxjava I/IT520: call: 4
6.Take
使用Take操作符让你可以修改Observable的行为,只返回前面的N项数据,然后发射完成通知,忽略剩余的数据。示例代码
Observable.just(1, 2, 3, 4, 5, 6, 7, 8) .take(4) .subscribe(new Subscriber<Integer>() { @Override public void onNext(Integer item) { System.out.println("Next: " + item); } @Override public void onError(Throwable error) { System.err.println("Error: " + error.getMessage()); } @Override public void onCompleted() { System.out.println("Sequence complete."); } });
输出
Next: 1 Next: 2 Next: 3 Next: 4 Sequence complete.
7.TakeLast
使用TakeLast操作符修改原始Observable,你可以只发射Observable’发射的后N项数据,忽略前面的数据。示例代码
Observable.just(1, 2, 3, 4, 5, 6, 7, 8) .takeLast(4) .subscribe(new Subscriber<Integer>() { @Override public void onNext(Integer item) { System.out.println("Next: " + item); } @Override public void onError(Throwable error) { System.err.println("Error: " + error.getMessage()); } @Override public void onCompleted() { System.out.println("Sequence complete."); } });
输出
Next: 5 Next: 6 Next: 7 Next: 8 Sequence complete.
8.Sample
对发送的数据进行一定频率的采样发送Observable .interval(1000, TimeUnit.MILLISECONDS)//每秒发送1个数字 .sample(2000,TimeUnit.MILLISECONDS)//每2秒采样一次 .subscribe(new Action1<Long>() { @Override public void call(Long aLong) { Log.i(TAG, "call: "+aLong); } });
上面的代码打印:0,2,4,6,8。。。。
9.IgnoreElements
如果你不关心一个Observable发射的数据,但是希望在它完成时或遇到错误终止时收到通知,你可以对Observable使用ignoreElements操作符,它会确保永远不会调用观察者的onNext()方法。Observable.just(1, 2, 3, 4, 1) .ignoreElements()//不发送任何信息 直接发送onCompleted() .subscribe(new Subscriber<Integer>() { @Override public void onCompleted() { Log.i(TAG, "onCompleted: "); } @Override public void onError(Throwable e) { } @Override public void onNext(Integer integer) { Log.i(TAG, "onNext: "+integer); } });
相关文章推荐
- RxJava操作符(04-过滤操作)
- RxJava操作符(04-过滤操作)
- 深入浅出RxJava_06[传输过程的条件&组合操作]
- 深入浅出RxJava_07[多线程&辅助操作(完)]
- WP7 XML操作详解:读取,过滤以及数据绑定
- 网站运维技术与实践之数据采集、传输与过滤
- Flex与.NET互操作(四):使用HttpService、URLReqeust和URLLoader加载/传输数据
- [Android应用开发] 04.页面跳转和数据传输
- ASP.NET 2.0中的数据操作之七:使用DropDownList过滤的主/从报表
- [翻译] Scott Mitchell 的ASP.NET 2.0数据操作教程之七:使用DropDownList过滤的主/从报表
- Asp.net/c#+OleDb操作excel文件(二),数据传输使用Parameters
- PHP数据的提交与过滤基本操作实例详解
- 多用户操作从mysql数据库传输到前台页面的数据
- STM32F4 ADC采集数据的DMA数据传输【库函数操作】
- 使用CoreData查询数据:谓词过滤,排序操作
- 深入浅出RxJava_03[被观察者创建操作]
- 在ASP.NET 2.0中操作数据之三十三:基于DataList和Repeater使用DropDownList过滤的主/从报表
- RxJava 事件流之过滤数据
- WP7的XML操作详解:读取,过滤以及数据绑定
- 【转】Flex与.NET互操作(四):使用HttpService、URLReqeust和URLLoader加载/传输数据