这篇,我们讲几个条件判断和布尔值操作相关的操作符。
All操作符。判定是否Observable发射的所有数据都满足某个条件。就是判断某个数据源发射的数据是否符合规则,然后输出一个Boolean类型的返回值。(这里有小伙伴就会问了,这效果和filter不是一样的吗?其实的确是一样的,只是filter不会改变上游的数据类型,而all操作符则强制输出类型为Boolean值类型,所以使用all还是filter,看场景。)
image.png
- 例如,在一个问题列表中,点击条目,跳转到聊天室,自动发送多条问题消息。(有点像京东、天猫找客服,自动发一些确定的问题)
/**
* 自动批量发送消息
*/
public Observable<Boolean> autoSendMsgList(ArrayList<AutoSendMsgModel> autoSendMsgList) {
return Observable.fromIterable(autoSendMsgList)
.flatMap(new Function<AutoSendMsgModel, ObservableSource<Boolean>>() {
@Override
public ObservableSource<Boolean> apply(AutoSendMsgModel model) throws Exception {
return sendTextMsg(model.getMsg());
}
})
.all(new Predicate<Boolean>() {
@Override
public boolean test(Boolean isSuccess) throws Exception {
return isSuccess;
}
}).toObservable();
}
- all操作符,判定每次发送的消息的返回结果都要为true,才算发送成功。
Amb操作符。给定两个或多个Observables,它只发射首先发射数据或通知的那个Observable的所有数据,其他被抛弃。意思就是竞争,谁先发送事件,谁就赢。不管是onNext(),还是onError或onCompleted()事件。
image.png
- 这个场景就很好理解了,例如我们请求接口前,先去找内存缓存,再找本地缓存,最后没有缓存可用,就请求接口数据,如果有缓存,那接口就不请求了。
Observable.ambArray(
Observable.create(new ObservableOnSubscribe<List<SearchTagModel>>() {
@Override
public void subscribe(ObservableEmitter<List<SearchTagModel>> emitter) throws Exception {
if (mHotTagCacheList.size() > 0) {
emitter.onNext(mHotTagCacheList);
emitter.onComplete();
}
}
})
.map(new Function<List<SearchTagModel>, BaseSearchModel>() {
@Override
public BaseSearchModel apply(List<SearchTagModel> tagModels) throws Exception {
mHotTagList.clear();
mHotTagList.addAll(tagModels);
return new HotSearchModel(tagModels);
}
}),
//热门搜索
mClient.requestTagsInObservable(TAG)
.filter(new Predicate<HttpModel<List<SearchTagModel>>>() {
@Override
public boolean test(HttpModel<List<SearchTagModel>> httpModel) throws Exception {
return httpModel.getData() != null && httpModel.getData().size() > 0;
}
})
.map(new Function<HttpModel<List<SearchTagModel>>, BaseSearchModel>() {
@Override
public BaseSearchModel apply(HttpModel<List<SearchTagModel>> httpModel) throws Exception {
//缓存
mHotTagCacheList.clear();
mHotTagCacheList.addAll(httpModel.getData());
mHotTagList.clear();
mHotTagList.addAll(httpModel.getData());
return new HotSearchModel(httpModel.getData());
}
}))
- 例如搜索功能,热门搜索,如果之前在前面一个界面已经请求过了,则可以直接带数据过来,直接使用,不再调接口拿。再或者前面没有请求过,没有缓存,则请求接口,再将数据缓存到集合(内存缓存)。
Contains操作符。判定一个Observable是否发射一个特定的值,并返回一个Boolean结果值。效果就是List集合.contains(object)的效果,判断某个值是否存在集合中,在RxJava中,Contains操作符就是判断某个数据集是否发出过指定的事件值。
image.png
- 例如,遍历列表数据集,判断是否存在某个类型的条目,存在或不存在做某些操作。
Object model = ...
Items items = new Items();
Observable.fromIterable(items)
.contains(model)
.as(RxLifecycleUtil.bindLifecycle(this))
.subscribe(new Consumer<Boolean>() {
@Override
public void accept(Boolean isContains) throws Exception {
//...
}
});
网友评论