【Android】RxJava轮询简示

RxJava轮询简示

• How To Use

​​创建​​

private var _connectJob: Disposable? = null

private fun startConnectJob() {
  if (_connectJob != null && _connectJob?.isDisposed == false) return
  _connectJob = Observable.interval(0, 5, TimeUnit.SECONDS)
      .subscribeOn(Schedulers.newThread())
        .subscribe {
          //your job
    }
}

private fun stopConnectJob() {
  if (_connectJob != null) {
      if (!_connectJob!!.isDisposed) {
          _connectJob!!.dispose()
            _connectJob = null
    }
  }
}

​​销毁​​

override fun onDestroy() {
  stopConnectJob()
  super.onDestroy()
}