intervalRange操作符
開(kāi)始前我們先來(lái)了解下intervalRange操作符（了解過(guò)的可以忽哈）。
intervalRange(long start, long count, long initialDelay, long period, TimeUnit unit)
start：起始數(shù)值
count：發(fā)射數(shù)量
initialDelay：延遲執(zhí)行時(shí)間
period：發(fā)射周期時(shí)間
unit：時(shí)間單位
一句話簡(jiǎn)介就是延遲initialDelay個(gè)unit單位后掷空，以period為周期肋殴，依次發(fā)射count個(gè)以start為初始值并遞增的數(shù)字囤锉。
布局
布局中放一個(gè)Button用來(lái)演示點(diǎn)擊獲取驗(yàn)證碼，并開(kāi)啟倒計(jì)時(shí)重新獲取的功能护锤。
<RelativeLayout xmlns:android="http://schemas.android.com/apk/res/android"
xmlns:tools="http://schemas.android.com/tools"
android:layout_width="match_parent"
android:layout_height="match_parent"
android:padding="15dp"
tools:context="com.holmeslei.rxjava2demo.ui.CountDownActivity">
<Button
android:id="@+id/btn_get_code"
android:layout_width="match_parent"
android:layout_height="wrap_content"
android:text="獲取驗(yàn)證碼" />
</RelativeLayout>
Activity
由于業(yè)務(wù)邏輯簡(jiǎn)單官地，所以就不整什么復(fù)雜的框架了，功能都在Activity中實(shí)現(xiàn)烙懦。
1.使用ButterKnife依賴注入獲取Button的實(shí)例及設(shè)置其點(diǎn)擊監(jiān)聽(tīng)方法驱入。
2.點(diǎn)擊Button后首先將其設(shè)置為不可點(diǎn)擊，然后初始化全局變量Disposable氯析。
3.使用Flowable的intervalRange操作符亏较，從0開(kāi)始每隔1s發(fā)射一個(gè)自增的數(shù)字，持續(xù)11次掩缓，延遲0s執(zhí)行雪情。這樣就設(shè)定好了10秒的倒計(jì)時(shí)，可根據(jù)實(shí)際需要修改時(shí)長(zhǎng)你辣。
4.由于需要刷新UI巡通，所以設(shè)定觀察者執(zhí)行在Android的UI線程。
5.在doOnNext的回調(diào)中更新Button的顯示UI舍哄，達(dá)到讀秒的效果宴凉。
6.在doOnComplete的完成回調(diào)中重新將Button設(shè)置為可點(diǎn)擊，然后設(shè)置顯示UI表悬。
7.最后調(diào)用后subscribe()訂閱弥锄，這樣一個(gè)完整的異步事件流就完成了。
8.別忘了在Activity銷毀時(shí)將全局Disposable取消訂閱銷毀掉签孔。使用RxJava將無(wú)用的Disposable及時(shí)銷毀是一個(gè)很好的習(xí)慣叉讥，否則后期就得忙著處理各種OOM異常啦窘行。
public class CountDownActivity extends AppCompatActivity {
@BindView(R.id.btn_get_code)
Button btnGetCode;
private Disposable mdDisposable;
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_count_down);
ButterKnife.bind(this);
}
@OnClick(R.id.btn_get_code)
public void onViewClicked() {
//點(diǎn)擊后置為不可點(diǎn)擊狀態(tài)
btnGetCode.setEnabled(false);
//從0開(kāi)始發(fā)射11個(gè)數(shù)字為：0-10依次輸出饥追，延時(shí)0s執(zhí)行，每1s發(fā)射一次罐盔。
mdDisposable = Flowable.intervalRange(0, 11, 0, 1, TimeUnit.SECONDS)
.observeOn(AndroidSchedulers.mainThread())
.doOnNext(new Consumer<Long>() {
@Override
public void accept(Long aLong) throws Exception {
btnGetCode.setText("重新獲取(" + (10 - aLong) + ")");
}
})
.doOnComplete(new Action() {
@Override
public void run() throws Exception {
//倒計(jì)時(shí)完畢置為可點(diǎn)擊狀態(tài)
btnGetCode.setEnabled(true);
btnGetCode.setText("獲取驗(yàn)證碼");
}
})
.subscribe();
}
@Override
protected void onDestroy() {
super.onDestroy();
if (mdDisposable != null) {
mdDisposable.dispose();
}
}
}
/**
* 使用RxJava1實(shí)現(xiàn)倒計(jì)時(shí)
*/
private void countDown() {
final long count = 30;
Observable.interval(1, TimeUnit.SECONDS)
.take(31)//計(jì)時(shí)次數(shù)
.map(new Func1<Long, Long>() {
@Override
public Long call(Long integer) {
return count - integer;
}
})
.doOnSubscribe(new Action0() {
@Override
public void call() {
cutdown.setEnabled(false);
cutdown.setBackgroundColor(Color.DKGRAY);
}
})
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Observer<Long>() {
@Override
public void onCompleted() {
cutdown.setEnabled(true);
cutdown.setBackgroundColor(getResources().getColor(R.color.colorPrimary));
cutdown.setText("倒計(jì)時(shí)");
}
@Override
public void onError(Throwable e) {
}
@Override
public void onNext(Long aLong) {
cutdown.setText("倒計(jì)時(shí)" + aLong);
}
});
}
