使用Java8流的构建器模式

Question

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

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

Answer 1

为Java 8流实现正确的foldleft并不难：

@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并行处理。我不同意这样的操作不适合流API，因为它可以通过已经存在的foreachordered来正确地表达。

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