如何将 Flux 从 Mono 中的列表中删除？

Question

我有一个带有一个包含列表的对象的 Mono。我需要从 Mono 中取出该列表并将其放入 Flux 中。

public Flux<Message> getMessages(String id) {
        return chatDAO.findById(id);
}

findById 方法接受一个聊天的 id 并返回 Mono<Chat> 其中Chat 有一个消息列表。我想获取该消息列表并将其转换为Flux<Messages>

Answer 1

您可以通过以下方式简单地使用Mono#flatMapMany 和Flux#fromIterable 方法的组合

public Flux<Message> getMessages(String id) {
    return chatDAO.findById(id)
                  .map(Chat::getMessages) //assumes that you have getter for your messages
                  .flatMapMany(Flux::fromIterable);
}