RxJava改造，获取列表并为每个项目添加额外信息

Question

我在玩RXJava，在Android系统中改装。我正在努力实现以下目标：

我需要定期调查一个电话，给我一个可观察的

一旦我得到这个列表，我想在每个交付迭代，并调用另一个方法，将给我的ETA（所以只是更多的信息）我想把这个新的信息附加到交付中，并返回完整的列表与附加到每个额外的信息项目。

一旦我得到了列表，我知道在没有rxjava的情况下如何做到这一点，但我想练习一下。

这是我目前的代码：

pollDeliveries = Observable.interval(POLLING_INTERVAL, TimeUnit.SECONDS, Schedulers.from(AsyncTask.THREAD_POOL_EXECUTOR))
            .map(tick -> RestClient.getInstance().getApiService().getDeliveries())
                    .doOnError(err -> Log.e("MPB", "Error retrieving messages" + err))
                    .retry()
                    .subscribe(deliveries -> {
                        MainApp.getEventBus().postSticky(deliveries);
                    });

这是给我的送货单。现在我想完成第二部分。

希望我说得够清楚。谢谢

Answer 1

我没有花太多时间使用Java8Lambdas，但下面是一个将每个对象映射到不同对象的示例，然后获得一个列表

List<Delivery> deliveries = ...;
Observable.from(deliveries).flatMap(new Func1<Delivery, Observable<ETA>>() {
    @Override
    public Observable<ETA> call(Delivery delivery) {
        // Convert delivery to ETA...
        return someEta;
    }
})
.toList().subscribe(new Action1<List<ETA>>() {
    @Override
    public void call(List<ETA> etas) {

    }
});

当然，最好能看到改装响应（可能是可见的）

要做到这一点，您可以改为这样做（使用lambdas会更好）。您将替换可观察的。从（交付）在上述示例中，具有以下内容：

apiService.getDeliveries().flatMap(new Func1<List<Delivery>, Observable<Delivery>>() {
    @Override
    public Observable<Delivery> call(List<Delivery> deliveries) {
        return Observable.from(deliveries);
    }
}).flatMap(...)

Answer 2

最后我找到了一个很好的方法。

private void startPolling() {
    pollDeliveries = Observable.interval(POLLING_INTERVAL, TimeUnit.SECONDS, Schedulers.from(AsyncTask.THREAD_POOL_EXECUTOR))
            .flatMap(tick -> getDeliveriesObs())
            .doOnError(err -> Log.e("MPB", "Error retrieving messages" + err))
            .retry()
            .subscribe(this::parseDeliveries, Throwable::printStackTrace);
}

private Observable<List<Delivery>> getDeliveriesObs() {
    return RestClient.getInstance().getApiService().getDeliveries()
            .flatMap(Observable::from)
            .flatMap(this::getETAForDelivery)
            .toSortedList((d1, d2) -> {
                if (d1.getEta() == null) {
                    return -1;
                }
                if (d2.getEta() == null) {
                    return 1;
                }
                return d1.getEta().getDuration().getValue() > d2.getEta().getDuration().getValue() ? 1 : -1;
            });
}

让我们一步一步走。

1. 首先，我们创建一个Observable，它在每次轮询间隔时间触发getDeliveriesSobs（）方法，该方法将返回最终列表

它工作正常，非常好，我开始喜欢rxjava:）