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

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

創(chuàng)新互聯(lián)提供網站設計、網站制作、網頁設計，成都品牌網站建設，廣告投放等致力于企業(yè)網站建設與公司網站制作，10多年的網站開發(fā)和建站經驗,助力企業(yè)信息化建設，成功案例突破上千,是您實現(xiàn)網站建設的好選擇.

之前有寫過Android實現(xiàn)倒計時之使用CountDownTimer，除了CountDownTimer，開發(fā)中我們也會用到handler，例如

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

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

首先添加類庫

// 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秒倒計時已結束");
          }
        });
  }

（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();
    }
  }

以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持創(chuàng)新互聯(lián)。

文章名稱：AndroidRxJava創(chuàng)建操作符Timer的方法
文章位置：http://bm7419.com/article22/jdgocc.html

成都網站建設公司_創(chuàng)新互聯(lián)，為您提供、移動網站建設、定制開發(fā)、營銷型網站建設、網站收錄、外貿建站

廣告

聲明：本網站發(fā)布的內容（圖片、視頻和文字）以用戶投稿、用戶轉載內容為主，如果涉及侵權請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內容未經允許不得轉載，或轉載時需注明來源： 創(chuàng)新互聯(lián)

營銷型網站建設