1.包裝緩慢的舊代碼
/**
* defer
* <p>
* 包裝緩慢的舊代碼
*/
@Test
public void test9() {
//這樣的話征炼，還是會阻塞主線程
Observable.just(blockMethod("A"))
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(var -> LogUtil.print(var.toString()));
//使用defer的話谆奥，就不會阻塞主線程
Observable.defer(() -> Observable.just(blockMethod("B")))
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(var -> LogUtil.print(var.toString()));
}
public String blockMethod(String msg) {
String result = "block:" + msg;
LogUtil.print(result);
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
return result;
}
2.線程切換
/**
* subscribeOn
* <p>
* 線程切換
*/
@Test
public void test1() {
Observable.just(1, 2, 3, 4)
.subscribeOn(Schedulers.io()) // 指定 just() 發(fā)生在 IO 線程
.observeOn(AndroidSchedulers.mainThread()) // 指定 subscribe() 的回調(diào)發(fā)生在主線程
.subscribe(var -> LogUtil.print("number:" + var));
}
3.同步的數(shù)據(jù)變換
/**
* map
* <p>
* 同步的數(shù)據(jù)變換
*/
@Test
public void test2() {
Observable.just("Hello, world!")
.map(s -> s + " -Dan")
.subscribe(s -> LogUtil.print(s));
}
4.異步的數(shù)據(jù)變換
/**
* flatMap
* <p>
* 異步的數(shù)據(jù)變換
*/
@Test
public void test3() {
Observable.just("Hello, world!")
.flatMap(s -> Observable.just(s + " -Dan"))
.subscribe(s -> LogUtil.print(s));
}
5.取數(shù)據(jù)的優(yōu)先級
/**
* concat
* <p>
* 取數(shù)據(jù)時，先查找內(nèi)存魄懂，再查找文件緩存闯第，最后才查找網(wǎng)絡
*/
@Test
public void test4() {
String memory = "內(nèi)存";
String file = "文件";
String net = "網(wǎng)絡";
Observable<String> memoryTask = Observable.create(subscriber -> {
if (!TextUtils.isEmpty(memory)) {
subscriber.onNext(memory);
} else {
subscriber.onCompleted();
}
});
Observable<String> fileTask = Observable.create(subscriber -> {
if (!TextUtils.isEmpty(file)) {
subscriber.onNext(file);
} else {
subscriber.onCompleted();
}
});
Observable<String> netTask = Observable.just(net);
//特別提醒：這里的memoryTask、fileTask千萬別用just創(chuàng)建蛛淋，否則的話會直接返回memoryTask的值(哪怕memory為空)
Observable.concat(memoryTask, fileTask, netTask)
.first()
.subscribe(str -> LogUtil.print(str));
}
6.等待多個請求完成
/**
* zip
* <p>
* 等待多個請求完成
*/
@Test
public void test5() {
LogUtil.print("開始請求");
Observable<String> getA = Observable.create(subscriber -> {
try {
Thread.sleep(1000);
LogUtil.print("A");
subscriber.onNext("A");
subscriber.onCompleted();
} catch (InterruptedException e) {
subscriber.onError(e);
}
});
Observable<String> getB = Observable.create(subscriber -> {
try {
Thread.sleep(2000);
LogUtil.print("B");
subscriber.onNext("B");
subscriber.onCompleted();
} catch (InterruptedException e) {
subscriber.onError(e);
}
});
Observable.zip(getA, getB, (a, b) -> zipAB(a, b))
.subscribe(var -> LogUtil.print(var));
}
private String zipAB(String a, String b) {
return a + "和" + b;
}
7.合并多個輸入框的最新數(shù)據(jù)
/**
* combineLatest
* <p>
* 合并多個輸入框的最新數(shù)據(jù)
*/
@Test
public void test52() {
LogUtil.print("開始請求");
Observable<String> userNameEt = Observable.just("YTR");
Observable<String> passwordEt = Observable.just("123456", "");
Observable.combineLatest(userNameEt, passwordEt, (username, password) -> validate(username, password))
.subscribe(var -> LogUtil.print(var + ""));
}
private Boolean validate(String username, String password) {
LogUtil.print("username=" + username + "\tpassword=" + password);
if (TextUtils.isEmpty(username)) {
return false;
}
if (TextUtils.isEmpty(password)) {
return false;
}
return true;
}
8.獲取輸入框的最新數(shù)據(jù)
/**
* debounce
* <p>
* 獲取輸入框的最新數(shù)據(jù)
*/
@Test
public void test82() {
LogUtil.print("開始");
Observable<Integer> mockEt = Observable.create(subscriber -> {
try {
subscriber.onNext(1);
Thread.sleep(500);
subscriber.onNext(2);
Thread.sleep(1500);
subscriber.onNext(3);
subscriber.onCompleted();
} catch (InterruptedException e) {
subscriber.onError(e);
}
});
mockEt.debounce(1, TimeUnit.SECONDS)//取1秒之內(nèi)的最后一次
.subscribe(var -> LogUtil.print(var.toString()));//輸出2哀蘑、3
}
9.防止連續(xù)點擊
/**
* throttleFirst
* <p>
* 防止連續(xù)點擊
*/
@Test
public void test8() {
LogUtil.print("開始");
Observable<Integer> mockBtn = Observable.create(subscriber -> {
try {
subscriber.onNext(1);
Thread.sleep(500);
subscriber.onNext(2);
Thread.sleep(1500);
subscriber.onNext(3);
subscriber.onCompleted();
} catch (InterruptedException e) {
subscriber.onError(e);
}
});
mockBtn.throttleFirst(1, TimeUnit.SECONDS)//取1秒之內(nèi)的第一次
.subscribe(var -> LogUtil.print(var.toString()));//輸出1绘迁、3
}
10.定時操作
/**
* interval
* <p>
* 定時操作
*/
@Test
public void test7() {
LogUtil.print("開始");
//延遲2秒后缀台，每隔3秒發(fā)送一次
Observable.interval(2, 3, TimeUnit.SECONDS)
.subscribe(var -> LogUtil.print(var.toString()));
}
11.復雜的數(shù)據(jù)變換
/**
* filter、distinct睛约、take哲身、reduce
* <p>
* 復雜的數(shù)據(jù)變換
*/
@Test
public void test6() {
Observable.just("1", "2", "2", "3", "4", "5")
.map(Integer::parseInt)//轉(zhuǎn)換為int
.filter(s -> s > 1)//取大于1
.distinct()//去重
.take(2)//取前兩位
.reduce((integer, integer2) -> integer.intValue() + integer2.intValue())//迭代計算
.subscribe(var -> LogUtil.print(var.toString()));//輸出：5
}
