[android]反复让 API 调用与改造和 rxjava

标签: Java Android
发布时间: 2016/10/10 21:14:27
注意事项: 本文中文内容可能为机器翻译,如要查看英文原文请点击上面连接.

我有改造 observable :

@GET("something/")
Observable<Something> getSomething();

订阅到它给出响应。

getSomething().subscribe(new Subscriber<Something>() {
            @Override
            public void onCompleted() {
            }

            @Override
            public void onError(Throwable e) {
            }

            @Override
            public void onNext(Something something) {
                //update database of something
            }
        });

如何可以作出此调用每隔 60 秒以便我可以相应地更新数据库?

解决方法 1:

首先请不要做它如果你能避免它。它是最好将更改 (例如 GCM) 而不是拉以节省电池及数据推送。

做到这一点你可以使用组合的 Observable.intervalObservable.repeat 运算符。

Observable.interval(60, TimeUnit.SECONDS)
    .flatMap(n -> getSomething())
    .repeat()
    .subscribe();

抱歉 lambda 时。

赞助商