Java 8流-列表的收集和流图

Question

我有一个列表的地图，并希望收集所有的值，然后流在收集的列表上，所以给出：-

Map<LocalDateTime, List<PublicationSession>> effectiveDatePublicationMap;

下面的工作/显示了我想用迭代做什么，但我想在流中做这些，而不是使用迭代创建一个中间列表：-

List< PublicationSession> publicationsToFilter = new ArrayList<>();
for (List< PublicationSession> sessions : effectiveDatePublicationMap.values()) {
    publicationsToFilter.addAll(sessions);
}

Collection< PublicationSession > wantedPublications = publicationsToFilter.stream()
            .filter(pub -> PublicationStatus.valueOf(pub.getPublishStatus()) == PublicationStatus.COMPLETE)
            .sorted(Comparator.comparing(PublicationSession::getCreateTime))
            .collect(toMap(p -> p.getPublicationSession().getEffDateTime(), UnaryOperator.identity(), PICK_LATEST))
            .values();

因此，我希望将列表的映射流化到一个列表中，然后在一个流中处理该子列表，而不是必须在两个语句中完成上述操作（即通过迭代构建列表，然后进行流化以筛选/排序和收集）。

到目前为止，我还没有做到这一点，当我尝试流式/收集地图时，我会遇到编译问题。有谁能演示一下如何在一个步骤中完成上述操作，而不需要在流式处理之后再进行迭代吗？

Answer 1

看起来您只需要flatmap原始映射的值，然后继续当前的处理：

Collection< PublicationSession > wantedPublications = 
    effectiveDatePublicationMap.values() // Collection<List<PublicationSession>>
                               .stream() // Stream<List<PublicationSession>>
                               .flatMap(list->list.stream()) // Stream<PublicationSession>
                               .filter(pub -> PublicationStatus.valueOf(pub.getPublishStatus()) == PublicationStatus.COMPLETE)
                               .sorted(Comparator.comparing(PublicationSession::getCreateTime))
                               .collect(toMap(p -> p.getPublicationSession().getEffDateTime(), UnaryOperator.identity(), PICK_LATEST))
                               .values();