使用 Java 8 Stream 的构建器模式

我正在用一个简单的循环构建一个对象：

WebTarget target = getClient().target(u);

for (Entry<String, String> queryParam : queryParams.entrySet()) {
    target = target.queryParam(queryParam.getKey(), queryParam.getValue());
}

我想使用 Java8 Stream API 做同样的事情，但我不知道如何做。让我挣扎的是每次都会重新分配目标，因此简单的 .forEach() 将不起作用。我想我需要使用 .collect() 或 reduce() 因为我正在寻找单个返回值，但我现在迷失了！

实施正确的方法并不困难foldLeft对于 Java 8 流：

@SuppressWarnings("unchecked")
public static <T, U> U foldLeft(Stream<T> stream, 
                                U identity, BiFunction<U, ? super T, U> accumulator) {
    Object[] result = new Object[] { identity };
    stream.forEachOrdered(t -> result[0] = accumulator.apply((U) result[0], t));
    return (U) result[0];
}

或者以类型安全的方式：

public static <T, U> U foldLeft(Stream<T> stream, 
                                U identity, BiFunction<U, ? super T, U> accumulator) {
    class Box {
        U value;
        Box(U value) { this.value = value; }
    }
    Box result = new Box(identity);
    stream.forEachOrdered(t -> result.value = accumulator.apply(result.value, t));
    return result.value;
}

这适用于顺序流和并行流。如果您的流具有一些消耗 CPU 的无状态中间操作，例如map：在这种情况下，可以通过以下方式处理下一个元素map与当前元素并行处理foldLeft。我不同意这样的操作不适合Stream API，因为它可以通过已经存在的正确表达forEachOrdered.

我有这个操作StreamEx https://github.com/amaembo/streamex库，所以你可以像这样使用它：

WebTarget target = EntryStream.of(queryParams).foldLeft(getClient().target(u), 
        (t, entry) -> t.queryParam(entry.getKey(), entry.getValue()))