// 轮询器
开启页面5秒后 每隔10秒走一次
private Disposable mdDisposable;
mdDisposable = Flowable.interval(5, 10, TimeUnit.SECONDS)
.doOnNext(new Consumer<Long>() {
@Override
public void accept(Long integer) throws Exception {
Log.i("asbcsdbvychvsdch", "走了");
}
}).subscribe();
// 销毁 mdDisposable.dispose(); 这个是销毁
