定期订阅来自 Retrofit 的 Observable

Question

我正在尝试使用 Retrofit 运行 REST api 调用并让它返回并可观察，但目前我只能弄清楚如何将其设置为延迟，但不幸的是跳过了“第一个间隔”

在这里我试图获取联系人列表

public interface IContactWebApi {

    @GET ("api/GetContactsByGroup")

    Observable<Groups> getContactsByGroupSync(@Query ("id") String deviceUid);

}

这是我使用延迟获得可观察值的地方

public void syncContacts(String address, String uid, int interval) {

   Retrofit retrofit = getRetrofit(address, true);

    Observable<List<Group>> groupObservable = retrofit.create(IContactWebApi.class)

            .getContactsByGroupSync(id)

            .subscribeOn(Schedulers.io())

            .delay(interval, TimeUnit.SECONDS)

            .onErrorResumeNext(Observable.empty())

            .repeat()

            .observeOn(AndroidSchedulers.mainThread());

        groupObservable.subscribe(groups -> handleGroups(groups));

}

我看到了一些建议 Observable.interval 的建议，但我似乎不知道如何将其与另一个间隔一起使用。到目前为止，我能做的最好的事情就是无延迟地运行一次，然后在 subscribe lamda 中，我将可观察值替换为有延迟的可观察值

    Observable<List<Group>> groupObservable = retrofit.create(IContactWebApi.class)

            .getContactsByGroupSync(uid)

            .map(Groups::getGroups)

            .subscribeOn(Schedulers.io())

            .onErrorResumeNext(Observable.empty())

            .observeOn(AndroidSchedulers.mainThread());

    groupObservable.subscribe(groups -> {

        handleGroups(groups)

        retrofit.create(IContactWebApi.class)

                .getContactsByGroupSync(uid)

                .map(Groups::getGroups)

                .subscribeOn(Schedulers.io())

                .delay(interval, TimeUnit.SECONDS)

                .onErrorResumeNext(Observable.empty())

                .repeat()

                .observeOn(AndroidSchedulers.mainThread())

                .subscribe(groups2 -> handleGroups(groups2));

    });

有谁知道更好的方法来做到这一点？

Answer 1

看来你可以只interval使用flatMap：IContactWebApi&nbsp;api&nbsp;=&nbsp;retrofit.create(IContactWebApi.class); Observable.interval(interval,&nbsp;TimeUnit.SECONDS) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;.flatMap(i&nbsp;->&nbsp;api.getContactsByGroupSync(uid)) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;.map(Groups::getGroups) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;.subscribeOn(Schedulers.io()) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;.onErrorResumeNext(Observable.empty()) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;.observeOn(AndroidSchedulers.mainThread()) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;.subscribe(groups&nbsp;->&nbsp;handleGroups(groups));