如何在使用流API的函数更改字符串变量时跟踪它？

Question

我想使用Stream API在使用函数更改变量时跟踪变量。

我的代码：

public String encoder(String texteClair) {
    for (Crypteur crypteur : algo) {
        texteClair = crypteur.encoder(texteClair);
    }
    return texteClair;
}

我有一个包含方法的类列表，我想在所有这些类中放入一个变量，就像上面代码中所做的那样。

它工作得很好，但我想知道如何用流来完成？

我们可以使用reduce（）？

Answer 1

我们可以使用reduce（）？

我想我们可以。但请记住，使用流并不是最好的情况。

因为您提到了复数形式的“类”，所以我假设Crypteur要么是抽象类，要么是接口。一般来说，你应该更喜欢接口而不是抽象类，所以我假设Crypteur是一个接口（如果不是，这不是一个大问题），并且它至少有一个类似的实现：

public interface Encoder {
    String encoder(String str);
}

public class Crypteur implements Encoder {
    private UnaryOperator<String> operator;
    
    public Crypteur(UnaryOperator<String> operator) {
        this.operator = operator;
    }
    
    @Override
    public String encoder(String str) {
        return operator.apply(str);
    }
}

然后，你可以利用你的编码器和流如下：

public static void main(String[] args) {
    List<Crypteur> algo =
        List.of(new Crypteur(str -> str.replaceAll("\\p{Punct}|\\p{Space}", "")),
                new Crypteur(str -> str.toUpperCase(Locale.ROOT)),
                new Crypteur(str -> str.replace('A', 'W')));
    
    String result = encode(algo, "Every piece of knowledge must have a single, unambiguous, authoritative representation within a system");

    System.out.println(result);
}

public static String encode(Collection<Crypteur> algo, String str) {
    return algo.stream()
        .reduce(str,
            (String result, Crypteur encoder) -> encoder.encoder(result),
            (result1, result2) -> { throw new UnsupportedOperationException(); });
}

请注意，combiner（用于并行合并部分结果）故意抛出异常，以指示此任务不可并行化。所有转换都必须按顺序应用，例如，我们不能在给定字符串上应用一些编码器，然后在给定字符串上分别应用其余的编码器，并合并两个结果——这是不可能的。

输出

EVERYPIECEOFKNOWLEDGEMUSTHWVEWSINGLEUNWMBIGUOUSWUTHORITWTIVEREPRESENTWTIONWITHINWSYSTEM

Answer 2

使用原子引用，它实际上是最终的，但其包装值可能会发生变化：

public String encoder(String texteClair) {
    AtomicReference<String> ref = new AtomicReference<>(texteClair);
    algo.stream().forEach(c -> ref.updateAndGet(c::encoder)); // credit Ole V.V
    return ref.get();
}