摘要：过滤类操作符主要包含等等。获取房源列表中的最后一套房源小区房源描述程序输出小区中粮海景壹号房源描述南北通透，豪华五房只发射观测序列中符合条件的最后一个数据项。
转载请注明出处：https://zhuanlan.zhihu.com/p/21966621
RxJava系列1(简介)
RxJava系列2(基本概念及使用介绍)
RxJava系列3(转换操作符)
RxJava系列4(过滤操作符)
RxJava系列5(组合操作符)
RxJava系列6(从微观角度解读RxJava源码)
RxJava系列7(最佳实践)
前面一篇文章中我们介绍了转换类操作符，那么这一章我们就来介绍下过滤类的操作符。顾名思义，这类operators主要用于对事件数据的筛选过滤，只返回满足我们条件的数据。过滤类操作符主要包含： Filter Take TakeLast TakeUntil Skip SkipLast ElementAt Debounce Distinct DistinctUntilChanged First Last等等。
Filterfilter(Func1)用来过滤观测序列中我们不想要的值，只返回满足条件的值，我们看下原理图：
还是拿前面文章中的小区Community[] communities来举例，假设我需要赛选出所有房源数大于10个的小区，我们可以这样实现：
Observable.from(communities)
.filter(new Func1() {
@Override
public Boolean call(Community community) {
return community.houses.size()>10;
}
}).subscribe(new Action1() {
@Override
public void call(Community community) {
System.out.println(community.name);
}
});
Take
take(int)用一个整数n作为一个参数，从原始的序列中发射前n个元素.
现在我们需要取小区列表communities中的前10个小区
Observable.from(communities)
.take(10)
.subscribe(new Action1() {
@Override
public void call(Community community) {
System.out.println(community.name);
}
});
TakeLast
takeLast(int)同样用一个整数n作为参数，只不过它发射的是观测序列中后n个元素。
获取小区列表communities中的后3个小区
Observable.from(communities)
.takeLast(3)
.subscribe(new Action1() {
@Override
public void call(Community community) {
System.out.println(community.name);
}
});
TakeUntil
takeUntil(Observable)订阅并开始发射原始Observable，同时监视我们提供的第二个Observable。如果第二个Observable发射了一项数据或者发射了一个终止通知，takeUntil()返回的Observable会停止发射原始Observable并终止。
ObservableobservableA = Observable.interval(300, TimeUnit.MILLISECONDS); Observable observableB = Observable.interval(800, TimeUnit.MILLISECONDS); observableA.takeUntil(observableB) .subscribe(new Subscriber () { @Override public void onCompleted() { System.exit(0); } @Override public void onError(Throwable e) { } @Override public void onNext(Long aLong) { System.out.println(aLong); } }); try { Thread.sleep(Integer.MAX_VALUE); } catch (InterruptedException e) { e.printStackTrace(); }
程序输出：
0 1
takeUntil(Func1)通过Func1中的call方法来判断是否需要终止发射数据。
Observable.just(1, 2, 3, 4, 5, 6, 7)
.takeUntil(new Func1() {
@Override
public Boolean call(Integer integer) {
return integer >= 5;
}
}).subscribe(new Action1() {
@Override
public void call(Integer integer) {
System.out.println(integer);
}
});
程序输出：
1 2 3 4 5Skip
skip(int)让我们可以忽略Observable发射的前n项数据。
过滤掉小区列表communities中的前5个小区
Observable.from(communities)
.skip(5)
.subscribe(new Action1() {
@Override
public void call(Community community) {
System.out.println(community.name);
}
});
SkipLast
skipLast(int)忽略Observable发射的后n项数据。
ElementAtelementAt(int)用来获取元素Observable发射的事件序列中的第n项数据，并当做唯一的数据发射出去。
Debouncedebounce(long, TimeUnit)过滤掉了由Observable发射的速率过快的数据；如果在一个指定的时间间隔过去了仍旧没有发射一个，那么它将发射最后的那个。通常我们用来结合RxBing(Jake Wharton大神使用RxJava封装的Android UI组件)使用，防止button重复点击。
debounce(Func1)可以根据Func1的call方法中的函数来过滤，Func1中的中的call方法返回了一个临时的Observable，如果原始的Observable在发射一个新的数据时，上一个数据根据Func1的call方法生成的临时Observable还没结束，那么上一个数据就会被过滤掉。
Distinctdistinct()的过滤规则是只允许还没有发射过的数据通过，所有重复的数据项都只会发射一次。
过滤掉一段数字中的重复项：
Observable.just(2, 1, 2, 2, 3, 4, 3, 4, 5, 5)
.distinct()
.subscribe(new Action1() {
@Override
public void call(Integer i) {
System.out.print(i + " ");
}
});
程序输出：
2 1 3 4 5
distinct(Func1)参数中的Func1中的call方法会根据Observable发射的值生成一个Key，然后比较这个key来判断两个数据是不是相同；如果判定为重复则会和distinct()一样过滤掉重复的数据项。
假设我们要过滤掉一堆房源中小区名重复的小区：
