1.gradle配置
implementation'io.reactivex.rxjava2:rxjava:2.2.10'
implementation'io.reactivex.rxjava2:rxandroid:2.1.1'
2.使用
Disposable disposable = Observable.interval(0, 2, TimeUnit.SECONDS)
? ? ? ? .subscribeOn(Schedulers.io())
? ? ? ? .observeOn(AndroidSchedulers.mainThread())
? ? ? ? .subscribe(new Consumer<Long>() {
? ? ? ? ? ? @Override
? ? ? ? ? ? public void accept(Long aLong) throws Exception{
? ? ? ? ? ? }
} });
3.停止
disposable.dispose()
