合并 Flux 结果并返回 Flux

Question

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

获取EventDocument的API调用

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 并返回Flux<Event>？

Answer 1

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