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()
