我正在使用RxJava在Android中制作一个计时器。我需要使用RxJava制作一个计时器,每秒钟发出一个observable。我尝试了以下方法,但都没有成功。你认为我做错了什么吗?
Observable.interval(1000L, TimeUnit.MILLISECONDS)
.timeInterval()
.observeOn(AndroidSchedulers.mainThread())
.subscribe({Log.d(LOG_TAG, "&&&& on timer") })
disposable = Observable.interval()....
然后在 Activity 的 onDestroy 中使用disposable.dispose()
。 - kukroid