RxJava：如果第一次成功，如何进行第二次 api 调用，然后创建组合响应

Question

这就是我想要做的：

打电话先休息API
if first succeeds call seconds rest API
如果两者都成功 -> 创建聚合响应

我在 Micronaut 中使用 RxJava2。

这是我的资料，但我不确定它是否正确。如果第一个或第二个 API 调用失败会怎样？

@Singleton
public class SomeService {
    private final FirstRestApi firstRestApi;
    private final SecondRestApi secondRestApi;

    public SomeService(FirstRestApi firstRestApi, SecondRestApi secondRestApi) {
        this.firstRestApi = firstRestApi;
        this.secondRestApi = secondRestApi;
    }

    public Single<AggregatedResponse> login(String data) {
        Single<FirstResponse> firstResponse = firstRestApi.call(data);
        Single<SecondResponse> secondResponse = secondRestApi.call();
        return firstResponse.zipWith(secondResponse, this::convertResponse);
    }

    private AggregatedResponse convertResponse(FirstResponse firstResponse, SecondResponse secondResponse) {
        return AggregatedResponse
                   .builder()
                   .something1(firstResponse.getSomething1())
                   .something2(secondResponse.getSomething2())
                   .build();
    }
}

Answer 1

这应该很简单

public Single<AggregatedResponse> login(String data) {
    return firstRestApi.call(data)
             .flatMap((firstResponse) -> secondRestApi.call().map((secondResponse) -> {
                 return Pair.create(firstResponse, secondResponse);
             })
             .map((pair) -> {
                 return convertResponse(pair.getFirst(), pair.getSecond());
             });
}

在这种情况下，您不再需要 zipWith。错误只是像往常一样进入错误流。

RxJava：如果第一次成功，如何进行第二次 api 调用，然后创建组合响应

RxJava: how to do a second api call if first is successful and then create a combinded response

rx-java2

micronaut