/** * Copyright 2015-2018 Hive Box. */package com.fcbox.locker.shrail.utils;import android.support.annotation.NonNull;import com.fcbox.locker.sdk.Locker;import com.fcbox.locker.sdk.log.LogUtils;import java.util.concurrent.TimeUnit;import io.reactivex.Observable;import io.reactivex.Observer;import io.reactivex.android.schedulers.AndroidSchedulers;import io.reactivex.disposables.Disposable;/** * Rxjava2.x實現輪詢定時器. * * @author xuzhuyun */public class RxTimerUtil { private static Disposable mDisposable; /**  * milliseconds毫秒后執行next操作  */ public static void timer(long milliseconds, final IRxNext next) {  Observable.timer(milliseconds, TimeUnit.MILLISECONDS)    .observeOn(AndroidSchedulers.mainThread())    .subscribe(new Observer<Long>() {     @Override     public void onSubscribe(@NonNull Disposable disposable) {      mDisposable = disposable;     }     @Override     public void onNext(@NonNull Long number) {      if (next != null) {       next.doNext(number);      }     }     @Override     public void onError(@NonNull Throwable e) {      //取消訂閱      cancel();     }     @Override     public void onComplete() {      //取消訂閱      cancel();     }    }); } /**  * 每隔milliseconds毫秒后執行next操作  */ public static void interval(long milliseconds, final IRxNext next) {  Observable.interval(milliseconds, TimeUnit.MILLISECONDS)    .observeOn(AndroidSchedulers.mainThread())    .subscribe(new Observer<Long>() {     @Override     public void onSubscribe(@NonNull Disposable disposable) {      mDisposable = disposable;     }     @Override     public void onNext(@NonNull Long number) {      if (next != null) {       next.doNext(number);      }     }     @Override     public void onError(@NonNull Throwable e) {     }     @Override     public void onComplete() {     }    }); } /**  * 取消訂閱  */ public static void cancel() {  if (mDisposable != null && !mDisposable.isDisposed()) {   mDisposable.dispose();   LogUtils.e("====Rx定時器取消======");  } } public interface IRxNext {  void doNext(long number); }}