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

Question

这就是我想做的：

1. 调用第一个休息 API
2. 如果第一次成功，则调用秒休息 API
3. 如果两者都成功 ->创建聚合响应

我在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.错误只是像往常一样进入错误流。