在应用收集之前，如何从流中删除零元素？

Question

我的流函数有时会返回null，当我收集它们时如何删除该null返回？

versions.stream().map(vs->{
        if(vs.matches("^matched string$")) {
                ...
                return new VersionNumber(tmp[0], tmp[1], tmp[2]));
        }
        return null;
    }).flatMap(Optional::stream).collect(Collectors.toList());

对于此流函数，如果所有匹配均为false，则是指map（）方法中的所有功能，它将上升nullpointException。

如何使此流不引起异常，并且当所有元素均为null使其返回空列表或null？

Answer 1

您可以后来过滤

versions.stream().map(vs->{
        if(vs.matches("^matched string$")) {
                ...
                return new VersionNumber(tmp[0], tmp[1], tmp[2]));
        }
        return null;
    }).filter(Objects::nonNull).flatMap(Optional::stream).collect(Collectors.toList());

，但这是更明智的过滤

versions.stream().filter(vs -> vs.matches("^matched string$"))
                 .map(vs->{
                           ...
                           return new VersionNumber(tmp[0], tmp[1], tmp[2]));
    }).flatMap(Optional::stream).collect(Collectors.toList());

Answer 2

如果所有匹配都是错误的，我的意思是，如果所有函数在.map方法中，则它将上升nullpointException

因为您正在获得nullpointerexception，这意味着您的代码编译和编译代码跑步。因此，我假设map（）操作中的“代码”不是您的实际代码选项。

flatmap（可选:: stream）仅当先前的map（）产生类型可选＆lt; versionNumber＆gt;时，才不会导致汇编错误。

因此，我的建议很简单：永远不会返回 null 代替可选的。当可选对象可能是null时，它应该包含一个值或为空是完全错误的，但绝不应该是null。

正如 @andy thomas 在评论中指出的那样，如果no 如果可选如果代码map（）中的代码（）真正在现场创建对象，例如new versionNumber（TMP [0]，TMP [1]，TMP [2]））;。在这种情况下，将map（）的结果与可选一起包装，将是对可选的滥用。返回versionNumber实例或null。然后应用一个过滤器：

    .map(vs -> {
            if (vs.matches("^matched string$")) {
            ...
            return new VersionNumber(tmp[0], tmp[1], tmp[2]);
        }
        return null;
    })
    .filter(Objects::nonNull)
    .collect(Collectors.toList());

您必须求助于可选的 ，如果您实际上是不是而不是创建version> versionnumber当您've显示了，但是，例如，如果某种条件是肉，请返回可选＆gt;的API调用。

    .map(vs -> {
        if (vs.matches("^matched string$")) {
            ...
            return getVersionNumber(tmp[0], tmp[1], tmp[2]); // method returing Optional<VersionNumber>
        }
        return Optional.empty();
    })
    .flatMap(Optional::stream)
    .collect(Collectors.toList());

在这种情况下，无需应用过滤。 optional.stream（）在空的可选时调用时会产生一个空流。

Answer 3

从Java 16开始，还有 stream.mapmulti ：

返回由由多个元素替换该流的每个元素的结果的流，特别是 Zero 或更多元素。

（强调矿山）

使用此矿场，您的示例变为：

versions.stream().mapMulti((vs, consumer)->{
        if(vs.matches("^matched string$")) {
                ...
                consumer.accept(new VersionNumber(tmp[0], tmp[1], tmp[2]));
        }    
}).collect(Collectors.toList());

请注意，零值根本不是下游发射的，因此无需过滤或中间流以进行平面映射。

---

另一个例子：

record A(String name, long count) {}

public static void main(String[] args) {
    Stream.of(new A("apple", 1), new A("orange", 3), new A("banana", 0))
        .mapMulti((bucket, consumer) -> {
            for (int i = 0; i < bucket.count(); i++) {
                consumer.accept(bucket.name());
            }
        })
        .forEachOrdered(System.out::println);       
}

印刷：

apple
orange
orange
orange

3个橙子，但没有香蕉