最新国产好看的视频,伊人天堂AV在线,国产Aaaaaa视频,蜜臀视频在线观看一区,人妻av色图,密臀久久久精品影片,青青视频免费观看毛片,久草在线观看视,国产三级精品色情在线

輕松實現(xiàn)Rxjava定時器功能

 更新時間:2018年06月28日 11:28:15   作者:MillerKevin  
這篇文章主要為大家詳細介紹了Rxjava實現(xiàn)定時器功能的兩種方式,具有一定的參考價值,感興趣的小伙伴們可以參考一下

使用RxJava實現(xiàn)定時器功能可以通過兩種方式來實現(xiàn),具體實現(xiàn)如下:

一、使用 timer 操作符

private Disposable mDisposable;

 /**
  * 啟動定時器
  */
 public void startTime() {

  Observable.timer(10, TimeUnit.SECONDS)
    .subscribeOn(Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe(new Observer<Long>() {
     @Override
     public void onSubscribe(Disposable d) {
      mDisposable = d;
     }

     @Override
     public void onNext(Long value) {
      //Log.d("Timer",""+value);
     }

     @Override
     public void onError(Throwable e) {

     }

     @Override
     public void onComplete() {
      // TODO:2017/12/1
      closeTimer();
     }
    });
 }


 /**
  * 關閉定時器
  */
 public void closeTimer(){
  if (mDisposable != null) {
   mDisposable.dispose();
  }
 }

二、使用使用 intervaltake 操作符

在1.x 中 timer 可以執(zhí)行間隔邏輯,在2.x中此功能已過時,交給了 interval 操作符,當然只使用 interval 還不能實現(xiàn)定時器功能,必須再結合take 操作符。具體代碼如下:

private Disposable mDisposable;

 /**
  * 啟動定時器
  */
 public void startTime() {
  int count_time = 10; //總時間
  Observable.interval(0, 1, TimeUnit.SECONDS)
    .take(count_time+1)//設置總共發(fā)送的次數(shù)
    .map(new Function<Long, Long>() {
     @Override
     public Long apply(Long aLong) throws Exception {
      //aLong從0開始
      return count_time-aLong;
     }
    })
    .subscribeOn(Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe(new Observer<Long>() {
     @Override
     public void onSubscribe(Disposable d) {
      mDisposable = d;
     }

     @Override
     public void onNext(Long value) {
      //Log.d("Timer",""+value);
     }

     @Override
     public void onError(Throwable e) {

     }

     @Override
     public void onComplete() {
      // TODO:2017/12/1
      closeTimer();
     }
    });
 }

 /**
  * 關閉定時器
  */
 public void closeTimer(){
  if (mDisposable != null) {
   mDisposable.dispose();
  }
 }

以上就是本文的全部內(nèi)容,希望對大家的學習有所幫助,也希望大家多多支持腳本之家。

相關文章

最新評論

仙居县| 梅河口市| 南岸区| 集安市| 迭部县| 兴海县| 海口市| 青州市| 永胜县| 武宁县| 双峰县| 黔西县| 温泉县| 明光市| 武陟县| 定西市| 龙泉市| 米脂县| 桦南县| 响水县| 长汀县| 东宁县| 镶黄旗| 应用必备| 且末县| 绥中县| 七台河市| 盐山县| 金坛市| 二连浩特市| 桓台县| 交城县| 高台县| 屏东市| 承德市| 新绛县| 错那县| 绍兴县| 庆阳市| 平原县| 漳平市|