Spring Boot Webclient-合并

Question

我想合并两个响应并返回一个流量。

private Flux<Response<List<Company>, Error>> loopGet(List<Entity> registries, Boolean status) {
    return Flux.fromIterable(registries)
            .flatMap(this::sendGetRequest)
            .mergeWith(Mono.just(fetch(status)));

}

这就是我正在做的，正在工作，但我希望在调用Mono.just（获取（状态））之前等待合并。我将解释，sendGetRequest返回一个Mono，该Mono进行API调用，并从结果将东西保存到db。随后，合并操作将调用带有读取方法的数据库，但该数据尚未更新。如果我再打一次电话，我就会得到更新的数据。

Answer 1

您需要concatWith和fromCallable以确保在get请求完成后延迟调用fetch。

private Flux<Response<List<Company>, Error>> loopGet(List<Entity> registries, Boolean status) {
    return Flux.fromIterable(registries)
            .flatMap(this::sendGetRequest)
            .concatWith(Mono.fromCallable(() -> fetch(status)));

}