在 ifPresent 中收集 lambda

Question

如何使用collect 方法在嵌套的ifPresent 方法中收集？

到目前为止，这是我所拥有的：

List result = list.stream()
                  .findFirst()
                  .ifPresent(info -> {
                      info.getMap()
                          .stream()
                          .filter( entry -> entry.getKey().equals("test"))
                          .map(entry::getValue)
                          .collect(Collectors.toList())                          
                   });

Answer 1

您可能想这样做：

List result = list.stream()
    .limit(1)
    .flatMap(info -> // <-- removed brace {
        info.getMap().stream()
            .filter( entry -> entry.getKey().equals("test"))
            .map(entry::getValue)
    ) // <-- removed brace here too
    .collect(Collectors.toList());

让我解释一下：

.limit(1)：将流限制在第一个元素（如果初始流为空，则返回空流）

.flatMap()：将流映射到新流。在这种情况下，将返回一个由来自 Entry#getValue() 的值组成的新流

.collect(Collectors.toList())：最后将值流收集到一个列表中。

正如 Olivier Grégoire 在 cmets 中所说，以下方法也有效：

List result = list.stream()
    .limit(1)
    .flatMap(info -> info.getMap().stream())
    .filter( entry -> entry.getKey().equals("test"))
    .map(entry::getValue)
    .collect(Collectors.toList());

在我看来，这更易读、更清楚地表明了意图是什么。

Answer 2

假设info.getMap 返回java.util.Map，我不明白为什么你需要内部流管道。

只需使用get("test")即可获取"test"键的值：

List result = 
    list.stream()
        .map(info -> info.getMap().get("test"))
        .filter(Objects::nonNull)
        .limit(1)
        .collect(Collectors.toList()); 

P.S.，不要使用原始类型。您应该将返回列表的类型更改为List<ValueType>，其中ValueType 是info.getMap() Map 中的值的类型。

Answer 3

看起来您有一个包含零个或多个Infos 的List<Info>，其中Info 是一个具有getMap() 方法的对象，该方法返回一个Map<String, Something>，而您希望得到一个@987654326 @，即第一个列表项的map中所有key为test的值。

您希望map 可选而不是使用ifPresent。 ifPresent 是终端操作，不返回任何内容（只是执行代码）。

list // List<Info>
    .stream() // Stream<Info>
    .findFirst() // Optional<Info>
    .map(info -> info.getMap().entrySet() // Set<Entry<String, Something>>
         .stream() // Stream<Entry<String, Something>>
         .filter(entry -> entry.getKey().equals("test"))
         .map(Entry::getValue) // Stream<Something>
         .collect(toList()) // List<Something>
    ) // Optional<List<Something>>
    .orElse(Collections::emptyList) // List<Something>

如果未指定最后一行，那么您将收到 Optional<List<Info>> 回复。

编辑：Lino 对limit 的回答更为惯用，除非您真的想以这种方式使用Optional，否则请选择那个。

编辑 2：

假设您上面的代码是您的完整业务逻辑，您可能只是在列表的第一项中找到“test”的值（感谢 Lino 提供limit）。那是：

list.stream() // Stream<List<Info>>
    .limit(1) // Stream<List<Info>> count 0/1
    .flatMap(info::getMap) Stream<Map<String, Something>> 0/1
    .map(map -> map.get("test")) Stream<Something> 0/1, possibly null
    .filter(Objects::nonNull) Stream<Something> 0/1
    .findFirst() Optional<Something>

为了完整起见，如果您想在列表中的地图中找到“test”的任何值，它会是：

list.stream() // Stream<List<Info>>
    .flatMap(info::getMap) Stream<Map<String, Something>> 
    .flatMap(map -> map.entrySet().stream()) // Stream<Entry<String, Something>>
    .filter(entry -> entry.getKey().equals("test"))
    .map(Entry::getValue) // Stream<Something>
    .collect(toList()) // List<Something>