向 Java 8 Stream 添加方法

Question

在使用 Java 8 Streams 时，我有时会发现 Stream 没有我想要的特定方法（例如 takeWhile()、dropWhile()、skipLast()）。如何在不重写整个 Java 8 Stream 架构的情况下创建自己的具有附加方法的流类？

我知道StreamEx 库并且知道它有takeWhile() 和dropWhile()。在撰写本文时，它没有skipLast()。我已经为此方法提交了an issue。

一个可接受的解决方案是展示如何扩展 Java 8 Stream 或 StreamEx。

Answer 1

自 0.5.4 版以来，StreamEx 库具有 chain() 方法。这允许创建方便插入的辅助方法。

public static <T> UnaryOperator<StreamEx<T>> skipLast(int n)
{
   return(stream -> skipLast(stream, n));
}

private static StreamEx<T> skipLast(Stream<T> input, int n)
{
   // implement the real logic of skipLast
}

有了上面的内容，现在可以写...

StreamEx.
   of(input).
   chain(skipLast(10)).
   forEach(System.out::println);