为现有流添加新价值

Question

有没有一种好方法可以向现有的流添加新值？我所能想象的是这样的：

public <T> Stream<T> addToStream(Stream<T> stream, T elem ) {
    List<T> result = stream.collect(Collectors.toList());
    result.add(elem);
    return result.stream();
}

但我正在寻找更简洁的东西，我可以在lambda表达式中使用，而不需要冗长。

当我试图实施PECS原则时，出现了另一个问题：

public <T> Stream<? super T> addToStream(Stream<? super T> stream, T elem ) {
    List<? super T> result = stream.collect(Collectors.toList()); //error
    result.add(elem);
    return result.stream();
}

似乎通配符不适用于流。收集，我想知道为什么。提前谢谢。

Answer 1

StreamEx库具有相应的方法。以下是如何使用它们的示例：

StreamEx.of("second").prepend("first").append("third").forEach(System.out::println);

输出如下：

first
second
third

Answer 2

怎么样

return Stream.concat(stream, Stream.of(elem));

这是假设原始流是有限的。如果不是，你可以按相反的顺序连接它们。

Answer 3

这个问题掩盖了一个错误的假设：流实际上包含它们的数据。他们没有；流不是数据结构，它们是跨各种数据源指定批量操作的一种方法。

有组合器用于将两个流合并为一个，例如Stream.concat，还有工厂用于从一组已知元素（Stream.of）或集合（Collection.stream）创建流。因此，如果您想生成一个新流，即您手中的流的串联，以及描述新元素的新流，您可以组合这些。

PECS示例中的问题是，出现了三次<代码>？假设它们描述了相同的类型，但它们没有。每次出现通配符都对应一个唯一的捕获，这不是您想要的；您需要为该类型变量命名，以便编译器知道列表的类型和输入流的类型是相同的。（此外，不要具体化集合；这很昂贵，如果流不是有限的，则可能是不终止的。只需使用concat即可。）所以答案是：你只是把泛型搞错了。这里有一种方法：

public<T> Stream<T> appendToStream(Stream<? extends T> stream, T element) {
    return Stream.concat(stream, Stream.of(element));
}

你把自己和PEC混淆了，因为你想“插入”到流中，而事实上你正在从中消费。