我正在尝试创建一个可观察对象,定期触发,但是出于某些原因,我无法弄清楚,它只会触发一次。有人能看出我做错了什么吗?
Observable<Long> observable = Observable.timer(delay, TimeUnit.SECONDS, Schedulers.io());
subscription = observable
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Action1<Long>() {
@Override
public void call(Long aLong) {
searchByStockHelper.requestRemoteSearchByStock();
}
});
目前延迟设置为2。