一個方法添加到Java 8個流

Question

雖然與Java 8 Stream s工作，我有時發現Stream沒有我的願望（例如takeWhile()，dropWhile()，skipLast()）的具體方法。我如何創建自己的流類，它具有額外的方法，無需重寫整個Java 8架構？

我知道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);