初識RxJava(六)判斷類 操作符
阿新 • • 發佈:2018-12-20
前言:
之前的 5 篇筆記已經將 RxJava 的操作符寫的差不多了,今天週五,雖然明天休息了,但是,生命不息學習不止,今天筆者來記錄一下 RxJava 的判斷類 操作符 。
正文:
1、all 操作符
1)、作用
判斷 被觀察者 發射的資料是否滿足規定條件,滿足的話,觀察者接收為 true、反之為 false;
2)、程式碼
/** * all 操作符 */ @SuppressLint("CheckResult") private void allMethod() { Observable.just(1, 2, 3, 4, 5, 6).all(new Predicate<Integer>() { @Override public boolean test(Integer integer) throws Exception { //判斷所有物件 是否都 小於 5 return integer < 5; } }).subscribe(new Consumer<Boolean>() { @Override public void accept(Boolean aBoolean) throws Exception { logDUtils("accept:" + aBoolean); } }); }
3)、效果
2、takeWhile 操作符
1)、作用
判斷髮送的每項資料是否滿足 設定的條件,滿足則傳送,不滿足的不傳送
2)、程式碼
/** * takeWhile */ @SuppressLint("CheckResult") private void takeWhileMethod() { Observable.just(1, 2, 3, 4, 5, 6).takeWhile(new Predicate<Integer>() { @Override public boolean test(Integer integer) throws Exception { return integer < 4; } }).subscribe(new Consumer<Integer>() { @Override public void accept(Integer integer) throws Exception { logDUtils("accept:" + integer); } }); }
3)、效果
3、skipWhile 操作符
1)、作用
判斷髮送的資料 是否滿足指定條件,輸出不符合條件的事件
2)、程式碼
/*** * skipWhile 操作符 */ @SuppressLint("CheckResult") private void skipWhileMethod() { Observable.just(1, 2, 3, 4, 5, 6, 7).skipWhile(new Predicate<Integer>() { @Override public boolean test(Integer integer) throws Exception { return integer<5; } }).subscribe(new Consumer<Integer>() { @Override public void accept(Integer integer) throws Exception { logDUtils("accept:" + integer); } }); }
3)、效果
4、takeUntil 操作符
1)、作用
當 被觀察者 傳送的事件滿足 指定條件時,停止傳送事件
2)、程式碼
/**
* takeUntil 操作符
*/
@SuppressLint("CheckResult")
private void takeUntilMethod() {
Observable.just(1, 2, 3, 4, 5, 6, 7).takeUntil(new Predicate<Integer>() {
@Override
public boolean test(Integer integer) throws Exception {
return integer == 5;
}
}).subscribe(new Consumer<Integer>() {
@Override
public void accept(Integer integer) throws Exception {
logDUtils("accept:" + integer);
}
});
}
3)、效果
5、skipUntil 操作符
1)、作用
當滿足某條件時 才是傳送資料
2)、程式碼
/**
* skipUntil 操作符
*/
@SuppressLint("CheckResult")
private void skipUntilMethod() {
Observable.interval(10, TimeUnit.MILLISECONDS)
.skipUntil(Observable.timer(80, TimeUnit.MILLISECONDS))
.subscribe(new Consumer<Long>() {
@Override
public void accept(Long aLong) throws Exception {
logDUtils("accept:" + aLong);
}
});
}
3)、效果
有沒有發現延遲了 7 才開始出現數據
6、SequenceEqual 操作符
1)、作用
判斷 兩個 被觀察者 傳送的資料是否相同
2)、程式碼
/**
* sequenceEqual 操作符
*/
@SuppressLint("CheckResult")
private void sequenceEqualMethod() {
Observable.sequenceEqual(Observable.just(1, 2, 3), Observable.just(1, 2, 3))
.subscribe(new Consumer<Boolean>() {
@Override
public void accept(Boolean aBoolean) throws Exception {
logDUtils("accept:" + aBoolean);
}
});
}
3)、效果
7、contains 操作符
1)、作用
判斷被觀察者傳送的資料 是否包含指定資料
2)、程式碼
/**
* contains 操作符
*/
@SuppressLint("CheckResult")
private void containsMethod() {
Observable.just(1, 2, 3, 4, "a", 4, 5, "b").contains("a").subscribe(new Consumer<Boolean>() {
@Override
public void accept(Boolean aBoolean) throws Exception {
logDUtils("accept:" + aBoolean);
}
});
}
3)、效果
表示發射的事件 內 包含 “a”.
8、isEmpty 操作符
作用
判斷 被觀察者發射的資料 是否為空;
9、amb 操作符
作用
當有多個 被觀察者 傳送資料的時候, 只發送先發出資料的觀察者的全部資料。
10、defaultIfEmpty 操作符
作用
不傳送 任何的 onNext 事件 只發送 一個 預設值 ,然後就傳送 onComplete 事件。