合并 Flux 结果和 return Flux

Question

我有一个 List<Event>，对于每个 Event，我需要设置 EventDocument。我从 api 得到 Flux<EventDocument>。我需要将正确的 EventDocument 映射到 Event 和 return Flux<Event>.

Api 调用获取 EventDocument

private Flux<EventDocument> getDocuments(List<Long> eventIds) {
    String url = this.documentServiceUrl + "/events?eventId=" + eventIds;
    return getWebClient()
            .post()
            .uri(url)
            .body(eventIds, List.class)
            .retrieve()
            .bodyToFlux(EventDocument.class)
            .log()
            .onErrorResume(error -> Flux.empty());
}

如何映射上面的结果以更正 Event 和 return Flux<Event>？

Answer 1

Flux<EventDocument> eventDocuments = ...;
Flux<Event> events = eventDocuments.map(mapToEventFunction);