重用流操作链

Question

我的想法是，我有一个特定的操作序列，我想应用于其他操作之间的几个流。流之间的其他操作不相同。

例如，对于每个流，我要更改字符串的大小写，修剪它，将空字符串清空，然后过滤掉空字符串，最后，消除重复，如下所示：

在这两种情况下,我都执行以下操作序列：

.map( String::trim ).map( Strings::emptyToNull ).filter( Objects::nonNull ).distinct()

我当前复制了该链并将其放在多个流的其他操作之间：

myStream1.doSomeStuff().map( String::trim ).map( Strings::emptyToNull ).filter( Objects::nonNull ).distinct().doOtherStuff();

myStream2.doSomethingElse().map( String::trim ).map( Strings::emptyToNull ).filter( Objects::nonNull ).distinct().doSomethingElseStill();

有没有一个好的方法来避免重写那段代码呢？很明显，这两个map（）操作是可能的，但是这种操作组合有什么办法吗？

Answer 1

您可以将流 包装在函数中

public Stream<String> trimAndFilterOutEmptyStringsAndGetDistinctElements(Stream<String> stream) {
    return stream.map(String::trim)
                 .map(Strings::emptyToNull) // or use not(String::isEmpty) like suggested below
                 .filter(Objects::nonNull)
                 .distinct();
}

可以这样使用

Stream<String> myStream1DownStream = trimAndFilterOutEmptyStringsAndGetDistinctElements(myStream1);
Stream<String> myStream2DownStream = trimAndFilterOutEmptyStringsAndGetDistinctElements(myStream2);

myStream1DownStream.doOtherStuff();
myStream2DownStream.doSomethingElseStill();

顺便说一句，我会使用

.filter(Predicate.not(String::isEmpty))  

.map(Strings::emptyToNull)
.filter(Objects::nonNull)

public class Extensions {
    public static Stream<String> trimAndFilterOutEmptyStringsAndGetDistinctElements(Stream<String> stream) {
        return stream.map(String::trim)
                     .map(Strings::emptyToNull) // or use not(String::isEmpty) like suggested below
                     .filter(Objects::nonNull)
                     .distinct();    
    }
}

myStream1.trimAndFilterOutEmptyStringsAndGetDistinctElements()
         .doOtherStuff();

null