欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

Android RxJava創(chuàng)建操作符Timer的方法

 更新時(shí)間：2017年12月27日 16:54:55   作者：Adan0520  
這篇文章主要為大家詳細(xì)介紹了Android RxJava創(chuàng)建操作符Timer的方法，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下

本文實(shí)例為大家分享了Android RxJava創(chuàng)建操作符Timer的具體代碼，供大家參考，具體內(nèi)容如下

之前有寫(xiě)過(guò)Android實(shí)現(xiàn)倒計(jì)時(shí)之使用CountDownTimer，除了CountDownTimer，開(kāi)發(fā)中我們也會(huì)用到handler，例如

mHandler.sendEmptyMessageDelayed(1, 10*1000);
  private Handler mHandler = new Handler() {
    @Override
    public void handleMessage(Message msg) {
      super.handleMessage(msg);
      Log.e("流程", "10秒時(shí)間已到");
    }
  };

現(xiàn)在結(jié)合RxJava來(lái)的Observable.timer操作符，既可以延遲執(zhí)行一段邏輯，也可以間隔執(zhí)行一段邏輯

首先添加類(lèi)庫(kù)

// RxAndroid
compile 'io.reactivex:rxandroid:1.2.1'
// RxJava
compile 'io.reactivex:rxjava:1.2.4'

（1）Timer 延遲10秒執(zhí)行：

private void timer() {
    Observable.timer(10000, TimeUnit.MILLISECONDS)
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe(new Action1<Long>() {
          @Override
          public void call(Long aLong) {
            Log.e("流程", "10秒倒計(jì)時(shí)已結(jié)束");
          }
        });
  }

（2）Timer 間隔1秒執(zhí)行：

 private Subscription subscribe;
  private void timer() {
    subscribe= Observable.timer(1000,1000,TimeUnit.MILLISECONDS).subscribe(new Subscriber<Long>() {
      @Override
      public void onCompleted() {
      }

      @Override
      public void onError(Throwable e) {

      }

      @Override
      public void onNext(Long aLong) {
        Log.e(TAG, "------>along："+aLong+" time:"+ SystemClock.elapsedRealtime());
      }
    });
  }

記得要取消訂閱

 private void stop() {
    if (subscribe != null && !subscribe.isUnsubscribed()) {
      subscribe.unsubscribe();
    }
  }

以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

相關(guān)文章

最新評(píng)論