怎么在Android中利用RxJava2实现一个倒计时功能-创新互联

怎么在Android中利用RxJava2 实现一个倒计时功能？很多新手对此不是很清楚，为了帮助大家解决这个难题，下面小编将为大家详细讲解，有这方面需求的人可以来学习下，希望你能有所收获。

导入必要的库文件（Android支持库和Reactivex系列支持库）

implementation 'com.android.support:appcompat-v7:27.1.0'
implementation 'com.android.support.constraint:constraint-layout:1.0.2'

implementation 'io.reactivex.rxjava2:rxandroid:2.0.2'
implementation 'io.reactivex.rxjava2:rxjava:2.1.10'

布局文件（很简单，只有一个TextView）

实现倒计时功能（代码清晰明了，也打出了相应的Log）

public class MainActivity extends AppCompatActivity {

  private static final String TAG = MainActivity.class.getSimpleName();

  private Disposable mDisposable;

  @Override
  protected void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);
    setContentView(R.layout.main_activity);

    final TextView tvCountDown = findViewById(R.id.tv_count_down);

    // 倒计时 10s
    mDisposable = Flowable.intervalRange(0, 11, 0, 1, TimeUnit.SECONDS)
        .observeOn(AndroidSchedulers.mainThread())
        .doOnNext(new Consumer() {
          @Override
          public void accept(Long aLong) throws Exception {
            Log.d(TAG, "倒计时");

            tvCountDown.setText("倒计时 " + String.valueOf(10 - aLong) + " 秒");
          }
        })
        .doOnComplete(new Action() {
          @Override
          public void run() throws Exception {
            Log.d(TAG, "倒计时完毕");

            Toast.makeText(MainActivity.this, "倒计时完毕", Toast.LENGTH_SHORT).show();
          }
        })
        .subscribe();
  }

  @Override
  protected void onDestroy() {
    super.onDestroy();

    if (mDisposable != null) {
      mDisposable.dispose();
    }
  }
}

看完上述内容是否对您有帮助呢？如果还想对相关知识有进一步的了解或阅读更多相关文章，请关注创新互联行业资讯频道，感谢您对创新互联的支持。