RxJava使用（二）filter 操作符

太过爱你忘了你带给我的痛 2021-09-16 01:50 324阅读 0赞

[https://blog.csdn.net/tangxl2008008/article/details/51334295][https_blog.csdn.net_tangxl2008008_article_details_51334295]

filter()操作符是可以对Observable流程的数据进行一层过滤处理，filter() 返回为 false 的值将不会发出到 Subscriber。

基本用法如下，下面的例子是过滤只保留偶数：

<table> 
 <tbody> 
  <tr> 
   <td>Observable.just(1, 2, 3, 4)<br> &nbsp; &nbsp; &nbsp; &nbsp; .filter(new Func1&lt;Integer, Boolean&gt;() { <br> &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; @Override<br> &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; public Boolean call(Integer integer) { <br> &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; return integer % 2 == 0;<br> &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; }<br> &nbsp; &nbsp; &nbsp; &nbsp; })<br> &nbsp; &nbsp; &nbsp; &nbsp; .subscribe(new Action1&lt;Integer&gt;() { <br> &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; @Override<br> &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; public void call(Integer integer) { <br> &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; Log.v(TAG, "data=" + integer);<br> &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; }<br> &nbsp; &nbsp; &nbsp; &nbsp; });</td> 
  </tr> 
 </tbody> 
</table>

输出结果：

data=2

data=4

说明：filter的实现是lift()的变换处理，详细请参考lift变换部分。另外，filter()返回了一个新的Observable，因此若不是采用上面这种直接流方式，而是分步调用方式，需要将新返回的Observable赋给原来的Observable。

[https_blog.csdn.net_tangxl2008008_article_details_51334295]: https://blog.csdn.net/tangxl2008008/article/details/51334295

发表评论取消回复

表情：

评论列表（有 0 条评论，324人围观）

还没有评论，来说两句吧...

相关阅读

相关 RxJava2 / RxJava2操作符scan

RxJava2 / RxJava2操作符scan scan操作符将Observable的结果在BiFunction扫描一遍后交给Observer使用，scan最大的功用

亦凉/ 2024年02月17日 22:07/ 0 赞/ 55 阅读

相关 RxJava使用说明4-过滤操作符

[RxJava使用说明1-简介][RxJava_1-] [RxJava使用说明2-基本概念及使用介绍][RxJava_2-] [RxJava使用说明3-转换操

约定不等于承诺〃/ 2022年10月30日 07:22/ 0 赞/ 175 阅读

相关 RxJava使用说明3-转换操作符

[RxJava使用说明1-简介][RxJava_1-] [RxJava使用说明2-基本概念及使用介绍][RxJava_2-] [RxJava使用说明3-转换操

冷不防/ 2022年10月30日 05:20/ 0 赞/ 160 阅读

相关深入浅出RxJava(二：操作符)

在 [第一篇blog][blog] 中，我介绍了RxJava的一些基础知识，同时也介绍了map()操作符。当然如果你并没有意愿去使用RxJava我一点都不诧异，毕竟才接触了这么

绝地灬酷狼/ 2022年09月26日 03:03/ 0 赞/ 177 阅读

相关 RxJava 之操作符

什么是RxJava RxJava 就是异步 RxJava 的异步实现，是通过一种扩展的观察者模式来实现的。一个响应式的编程框架什么是RxJava

心已赠人/ 2022年09月24日 10:20/ 0 赞/ 212 阅读

相关 RxJava操作符大全

> 转摘自作者： [maplejaw（https://blog.csdn.net/maplejaw\_/article/details/52396175）][maplejaw_

Bertha 。/ 2022年05月21日 22:21/ 0 赞/ 213 阅读

相关 RxJava操作符_1_filter_过滤范围

我们的一个Publisher 被多次订阅，如果每一个订阅者在订阅事件时都设置一个filter，那么这个filter是不是只对此订阅者有影响呢？还是对所有的订阅者都有影响呢？

不念不忘少年蓝@/ 2022年05月20日 03:27/ 0 赞/ 208 阅读

相关 RxJava操作符大全

方便使用时查找版权声明：本文为转载的博主原创文章。 https://blog.csdn.net/maplejaw\_/article/details/52396175

素颜马尾好姑娘i/ 2022年04月03日 02:56/ 0 赞/ 195 阅读

相关 RxJava源码阅读,map操作符(二)

1.基本写法 Observable.just("https://user-gold-cdn.xitu.io/2019/5/17/16ac4f7f486ca77a?

悠悠/ 2022年01月19日 04:25/ 0 赞/ 205 阅读

相关 RxJava使用（二）filter 操作符

[https://blog.csdn.net/tangxl2008008/article/details/51334295][https_blog.csdn.net_tangx

太过爱你忘了你带给我的痛/ 2021年09月16日 01:50/ 0 赞/ 325 阅读