RxJava2系列实践之倒计时功能(三)

前言

  通过本系列前两篇的学习,相信各位码友已经基本掌握RxJava2怎么使用了,本篇我们一起来通过一个小例子实践一下,也可以加深印象。来看看如何使用RxJava2的intervalRange操作符实现倒计时功能。
  

依赖

  首先添加依赖,Demo中使用了ButterKnife注入,各版本以当前最新的为准。

1
2
3
4
5
6
7
dependencies {
......
compile 'io.reactivex.rxjava2:rxjava:2.1.3'
compile 'io.reactivex.rxjava2:rxandroid:2.0.1'
compile 'com.jakewharton:butterknife:8.7.0'
annotationProcessor 'com.jakewharton:butterknife-compiler:8.7.0'
}

intervalRange操作符

  别着急上代码,开始前我们先来了解下intervalRange操作符(了解过的可以忽略哈)。
  intervalRange(long start, long count, long initialDelay, long period, TimeUnit unit)

  • start:起始数值
  • count:发射数量
  • initialDelay:延迟执行时间
  • period:发射周期时间
  • unit:时间单位

  一句话简介就是延迟initialDelay个unit单位后,以period为周期,依次发射count个以start为初始值并递增的数字。

布局

  布局中放一个Button用来演示点击获取验证码,并开启倒计时重新获取的功能。

1
2
3
4
5
6
7
8
9
10
11
12
13
<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="获取验证码" />
</RelativeLayout>

Activity

  由于业务逻辑简单,所以就不整什么复杂的框架了,功能都在Activity中实现。

  1. 第一步,使用ButterKnife依赖注入获取Button的实例及设置其点击监听方法。
  2. 第二步,点击Button后首先将其设置为不可点击,然后初始化全局变量Disposable。
  3. 第三步,使用Flowable的intervalRange操作符,从0开始每隔1s发射一个自增的数字,持续11次,延迟0s执行。这样就设定好了10秒的倒计时,可根据实际需要修改时长。
  4. 由于需要刷新UI,所以设定观察者执行在Android的UI线程。
  5. 在doOnNext的回调中更新Button的显示UI,达到读秒的效果。
  6. 在doOnComplete的完成回调中重新将Button设置为可点击,然后设置显示UI。
  7. 最后调用后subscribe()订阅,这样一个完整的异步事件流就完成了。
  8. 别忘了在Activity销毁时将全局Disposable取消订阅销毁掉。使用RxJava将无用的Disposable及时销毁是一个很好的习惯,否则后期就得忙着处理各种OOM异常啦。
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
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() {
//点击后置为不可点击状态
btnGetCode.setEnabled(false);
//从0开始发射11个数字为:0-10依次输出,延时0s执行,每1s发射一次。
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 {
//倒计时完毕置为可点击状态
btnGetCode.setEnabled(true);
btnGetCode.setText("获取验证码");
}
})
.subscribe();
}
@Override
protected void onDestroy() {
super.onDestroy();
if (mdDisposable != null) {
mdDisposable.dispose();
}
}
}

运行效果

  最后看一下运行效果Gif。


  运行效果

总结

  本篇文章利用RxJava2演示了一个倒计时的小栗子,更多的用法还待各位码友去探索与发现哈。
  进阶中的码猿一枚,写的不对的地方欢迎大神们留言指正,有什么疑惑或者建议也可以在我Github上RxJava2Demo项目Issues中提出,我会及时回复。
  附上RxJava2Demo的地址:
  RxJava2Demo

坚持原创技术分享,您的支持是我前进的动力,谢谢!