在项目中应用RxJava时，遇到了这样的使用场景：
模拟从服务器返回了一个列表。
private Observable<List<String>> getData() {
List<String> stringList = new ArrayList<>();
return Observable.just(stringList);
}
我在处理数据时，想判断一下这个list是不是空，如果不为空，显示数据，如果为空，给用户一个没有数据的提示。也就是我们常用的if和else操作。于是我是这样写的：
Observable<List<String>> observable = getData();
observable.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Consumer<List<String>>() {
@Override
public void accept(@NonNull List<String> strings) throws Exception {
if (strings != null && strings.size() > 0) {
// 显示数据
} else {
// 显示没有数据的提示
}
}
}, new Consumer<Throwable>() {
@Override
public void accept(@NonNull Throwable throwable) throws Exception {
// 错误处理
}
});
Filter
可是我觉得这样不够优雅不够RxJava，所以我想到了Filter操作符，能不能用它来帮我完成呢？于是我修改了一下我的代码。
Observable<List<String>> observable = getData();
observable.filter(new Predicate<List<String>>() {
@Override
public boolean test(@NonNull List<String> strings) throws Exception {
return strings != null && strings.size() > 0;
}
})
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Consumer<List<String>>() {
@Override
public void accept(@NonNull List<String> strings) throws Exception {
// 显示数据
}
}, new Consumer<Throwable>() {
@Override
public void accept(@NonNull Throwable throwable) throws Exception {
// 错误处理
}
});
来看一下Filter操作符的官方图示。
emit only those items from an Observable that pass a predicate test
它会按照我们给它的条件进行过滤，在本例中，只有当服务器返回的list不为null并且有数据时，
才会发出。这样的话，可以满足我有数据时显示数据的需求，但是没有数据时显示提示怎么办呢？
GroupBy
然后我想到了GroupBy这个操作符。
先看一下官方的图示吧。
divide an Observable into a set of Observables that each emit a different subset of items from the original Observable
它可以把一个Observable按照一定的条件分成多个Observable，在本例中，是否可以分成有数据和没数据两种呢？
我又修改了一下代码。
Observable<List<String>> observable = getData();
observable.groupBy(new Function<List<String>, Boolean>() {
@Override
public Boolean apply(@NonNull List<String> strings) throws Exception {
return strings != null && strings.size() > 0;
}
})
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Consumer<GroupedObservable<Boolean, List<String>>>() {
@Override
public void accept(@NonNull GroupedObservable<Boolean, List<String>> groupedObservable) throws Exception {
if (groupedObservable.getKey()) {
groupedObservable.subscribe(new Consumer<List<String>>() {
@Override
public void accept(@NonNull List<String> strings) throws Exception {
// 显示数据
}
});
} else {
groupedObservable.subscribe(new Consumer<List<String>>() {
@Override
public void accept(@NonNull List<String> strings) throws Exception {
// 显示没有数据的提示
}
});
}
}
}, new Consumer<Throwable>() {
@Override
public void accept(@NonNull Throwable throwable) throws Exception {
// 错误处理
}
});
关键在于，有一个新的GroupedObservable，它有一个getKey()方法，得到的这个key就是我们在groupBy操作符中返回的类型，本例中使用的是Boolean类型，根据不同的业务需要，也可以返回Integer或者String等等。
然后在Subscribe的时候，根据不同的key值，分为了不同的Observable，满足了我的需求。
SwitchIfEmpty
最近是实际使用中，发现如果使用GroupBy操作符，会比较复杂，特别是会生成了一个新的groupedObservable。
那么有没有更好的方法来实现if-else呢？
来看看另一个操作符吧，defaultIfEmpty。
Observable<List<String>> observable = getData();
observable
.filter(new Predicate<List<String>>() {
@Override
public boolean test(@NonNull List<String> strings) throws Exception {
return strings != null && strings.size() > 0;
}
})
.defaultIfEmpty(new ArrayList<>())
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Consumer<List<String>>() {
@Override
public void accept(@NonNull List<String> strings) throws Exception {
// 显示数据
}
}, new Consumer<Throwable>() {
@Override
public void accept(@NonNull Throwable throwable) throws Exception {
// 错误处理
}
});
当filter操作符判断不符合条件不发射时，可以通过defaultIfEmpty操作符添加一个默认的值。不过好像能做的事情不是很多。
所以我又换了一个switchIfEmpty操作符。
Observable<List<String>> observable = getData();
observable
.filter(new Predicate<List<String>>() {
@Override
public boolean test(@NonNull List<String> strings) throws Exception {
return strings != null && strings.size() > 0;
}
})
.switchIfEmpty(new Observable<List<String>>() {
@Override
protected void subscribeActual(Observer<? super List<String>> observer) {
List<String> newList = new ArrayList<>();
newList.add("new");
observer.onNext(newList);
observer.onComplete();
}
})
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Consumer<List<String>>() {
@Override
public void accept(@NonNull List<String> strings) throws Exception {
// 显示数据
}
}, new Consumer<Throwable>() {
@Override
public void accept(@NonNull Throwable throwable) throws Exception {
// 错误处理
}
});
效果是一样的，也是添加了默认值，不过能干的事情好像更多了一些。实际上看一下源码，发现其实差不太多。
@CheckReturnValue
@SchedulerSupport(SchedulerSupport.NONE)
public final Observable<T> defaultIfEmpty(T defaultItem) {
ObjectHelper.requireNonNull(defaultItem, "defaultItem is null");
return switchIfEmpty(just(defaultItem));
}
只是调用了switchIfEmpty(just(defaultItem))而已。
不过我发现了一个问题，如果我判断一个list是不是空，使用filter和switchIfEmpty结合起来是可以满足的，但是有些情况会有问题，看下面这个例子：
Observable.just(1, 2, 3, 4, 5)
.filter(new Predicate<Integer>() {
@Override
public boolean test(Integer integer) throws Exception {
return integer % 2 == 0;
}
})
.switchIfEmpty(new Observable<Integer>() {
@Override
protected void subscribeActual(Observer<? super Integer> observer) {
observer.onNext(-1);
observer.onComplete();
}
})
.subscribe(new Consumer<Integer>() {
@Override
public void accept(Integer integer) throws Exception {
System.out.println("integer = [" + integer + "]");
}
});
按照我的设想，应该是-1，2，-1，4，-1这么个顺序，然而结果却是2，4。这是为什么呢？
原来如果连续发射1，2，3，4，5的时候，filter操作符会过滤掉1，3，5，发射2和4，所以并不为空，所以switchIfEmpty就不会得到执行。比如我们只发射1，会被filter过滤掉，然后调用switchIfEmpty，得到-1；如果我们发射的是1和2，会得到2；如果发射1和3，也只会得到-1，而不是-1和-1，因为switchIfEmpty只会调用一次。
