RxJava 和 Retrofit - 链式服务响应

Question

RxJava 的新用户。试图实现一些微不足道的事情，但到目前为止我似乎无法理解整个RxJava 范式。我想要的只是一个接一个地进行两个服务调用，然后简单地返回一个包含两个调用响应的最终自定义POJO。这里需要注意的是，这两个调用是相互独立的。只有当第一个调用成功返回时，第二个才应该触发。第二个不使用来自第一个服务调用的任何数据。到目前为止我有什么。

 RestWebClient.get().getFirstImage()
                .flatMap(firstImage -> RestWebClient.get().getSecondImage())
                .subscribeOn(Schedulers.newThread())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(firstImage -> mainFragmentPresenterInterface.showImages(firstImage));

1. 我不确定如何链接两个单独的网络调用的响应并将它们作为单个 POJO 返回给演示者。

2. 另外，我们如何确保只有在 getFirstImage() 成功时才调用 getSecondImage()？

谢谢。

Answer 1

你的开始是正确的，我只是稍微修改一下你的sn-p：

RestWebClient.get().getFirstImage()
        .flatMap(firstImage -> /* first image success */ ? RestWebClient.get().getSecondImage() : Observable.just(null),
                (firstImage, secondImage) -> Pair.create(firstImage, secondImage))
        .subscribeOn(Schedulers.newThread())
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe(imagePair -> mainFragmentPresenterInterface.showImages(imagePair));