文章/答案/技术大牛

发布

社区首页 >问答首页 >对反应流中的项进行分组

问对反应流中的项进行分组
EN

Stack Overflow用户

提问于 2021-02-12 06:10:51

回答 1查看 49关注 0票数 0

假设我有这些对象的有限流

class Item {
    private int id;
    private List<Tag> tags;
}

Flux<Item> publisher;

假设以下是流中的项：

[
    {"id": 1, "tags": [{"value":"A"}]},
    {"id": 2, "tags": [{"value":"B"}]},
    {"id": 2, "tags": [{"value":"C"}]},
]

我想按id对它们进行分组，并将相应的值连接在一起。

[
    {"id": 1, "tag": [{"value":"A"}]},
    {"id": 2, "tag": [{"value":"B"}, {"value":"C"}]},
]

如何在发布者上执行此操作

发布于 2021-02-12 06:43:02

您可以使用允许使用Map<K, Collection<T>>的collectMultimap

publisher.collectMultimap(Item::getId)
     .subscribe(groupById -> System.out.println(groupById.toString()));

输出：

{1=[{"value":"A"}], 2=[{"value":"B"}, {"value":"C"}]}

票数 1

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/66163709

复制

相似问题

问对反应流中的项进行分组EN