private var mDisposable: Disposable? = null//在initVeiw中执行initLiveSocket就可以启动任务 //观看直播心跳 initialDelay：首次执行任务延迟多少 period：定时任务时间间隔 unit：时间单位
private fun initLiveSocket() {
mDisposable = Observable.interval(5, 10, TimeUnit.SECONDS)
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(object : Consumer {
override fun accept(t: Long?) {
LogUtil.e("------livePlayActivity定时轮询：$t")
mRoomInfo?.room_no?.let {
LiveSocketUtil.sendLive(this@LivePlayActivityKt, it.toInt())
}
}
})
}//在onDestroy()中执行下面代码关闭任务
//停止心跳包
mDisposable?.dispose()
【android rxjava实现定时任务】
推荐阅读
- 从零开发一个完整的Android项目（九）——图片浏览
- Android开发|ViewPager自适应高度问题
- Android|Android 指定销毁一个Activity
- 【Android】简单图片浏览器
- 理解ButterKnife（自动生成绑定资源的代码）
- MAC下搭建Android Studio
- NestedScrollingParent 和NestedScrollingChild 实现嵌套滑动
- android用shape画一条横线
- 华为推送 的坑
- Duplicate class com.alipay.a.a.a found in modules classes.jar (:alipaySdk-15.6.2-20190416165036:) an