Итак, я пытаюсь создать наблюдаемый, который срабатывает регулярно, но по какой-то причине, которую я не могу понять, он срабатывает только один раз. Может ли кто-нибудь увидеть, что я делаю неправильно?
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