我正在使用 RxAndroid observable
来检索一些对象(在本例中为 String)。我的服务如下所示:
public Observable<String> getRandomString() {
return Observable.create(new Observable.OnSubscribe<String>() {
@Override
public void call(Subscriber<? super String> subscriber) {
//code to retrieve result
subscriber.onNext("this is a string");
subscriber.onCompleted();
}
});
}
我在演示者中订阅并将结果发布到 View :
public void loadRandomString() {
Observable<String> observable = mService.getRandomString();
observable
.observeOn(AndroidSchedulers.mainThread())
.subscribeOn(Schedulers.newThread())
.subscribe(new Subscriber<String>() {
@Override
public void onCompleted() { }
@Override
public void onError(Throwable e) {
mMainView.onError(e.getLocalizedMessage());
}
@Override
public void onNext(String string) {
//do something with string
}
});
}
这一切都很好,但我希望这个操作是周期性的(每 x 分钟)。我可以使用 Timer
或 ScheduledThreadPoolExecutor
一遍又一遍地执行此操作,但我想看看 RxAndroid 领域是否有一些解决方案。我发现了一些 2013 年的旧解决方案,但此时很多代码已被弃用。这是否可以使用某种递归,或者我能否以更优雅的方式实现?
提前致谢!
最佳答案
您可能想要的是 Observable.interval()
.它按时间间隔发出。然后您可以将其平面映射到您的 Observable<String>
中,像这样:
Observable.interval(3, TimeUnit.MINUTES)
.flatMap(new Func1<Long, Observable<String>>() {
@Override
public Observable<String> call(Long ignore) {
return getRandomString();
}
})
.subscribe(...insert your subscriber here...);
就是说 - 如果您打算每隔几分钟执行一次此操作,您最好查看 AlarmManager或 JobScheduler ,因为用户很可能不会在那么长的一段时间内关注您的应用。
顺便说一句,使用 Observable.just("this is a string")
会容易得多比Observable.create()
.
关于android - 使用 RxAndroid 调度,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/34293804/