Java Stream：有没有一种方法可以迭代，每次使用两个元素而不是一个？

Question

Stream.of("a", "b", "err1", "c", "d", "err2", "e", "f", "g", "h", "err3", "i", "j");

Map<String, String> map = new HashMap<>();

Stream.of("a", "b", "err1", "c", "d", "err2", "e", "f", "g", "h", "err3", "i", "j")
.reduce((acc, next) -> {
    if (acc.startsWith("err"))
        map.put(acc,next);
    if (next.startsWith("err"))
        return next;
    else
        return "";
});

但我对它并不完全满意，主要有两个原因

1. 我“滥用”了reduce函数。在Stream API中，每个函数都有其明确、明确的用途:max被认为是计算最大值，filter被认为是根据条件进行筛选，reduce被认为是生成增量累加的值，等等。
2. 这样做会阻止我使用Streams强大的机制：如果我想将搜索限制在前两个结果上怎么办？

这里我使用了reduce，因为（据我所知）它是唯一一个允许比较两个值的函数，而这些值可以在某种程度上导致类似于“当前值”和“下一个值”的概念。

有没有更直截了当的办法？允许您在每次迭代时考虑多个值来迭代流的东西？

我所考虑的是一些机制，在给定当前元素的情况下，允许您为每次迭代定义一个“元素窗口”来考虑。

类似于

<R> Stream<R> mapMoreThanOne(
    int elementsBeforeCurrent,
    int elementsAfterCurrent,
    Function<List<? super T>, ? extends R> mapper);

而不是

<R> Stream<R> map(Function<? super T, ? extends R> mapper);

这将是对当前API的强大“升级”。

我感谢人们提出解决方案的努力，但问题不在于算法本身。有不同的方法来实现我的目标，把流，索引，临时变量存储以前的值...但我想知道在Stream API中是否有一些方法是为处理当前元素以外的元素而设计的，而不破坏“Stream范式”。像这样的东西

List<String> list =
        Stream.of("a", "b", "err1", "c", "d", "err2", "e", "f", "g", "h", "err3", "i", "j")
        .filterFunctionImWonderingIfExist(/*filters couples of elements*/)
        .limit(2)
        .collect(Collectors.toList());

在给出这些答案之后，我认为没有“清晰而快速”的解决方案，除非使用StreamEx库

Answer 1

可以为此任务生成自定义收集器。

Map<String, String> map = 
    Stream.of("a", "b", "err1", "c", "d", "err2", "e", "f", "g", "h", "err3", "i", "j")
          .collect(MappingErrors.collector());

与：

private static final class MappingErrors {

    private Map<String, String> map = new HashMap<>();

    private String first, second;

    public void accept(String str) {
        first = second;
        second = str;
        if (first != null && first.startsWith("err")) {
            map.put(first, second);
        }
    }

    public MappingErrors combine(MappingErrors other) {
        throw new UnsupportedOperationException("Parallel Stream not supported");
    }

    public Map<String, String> finish() {
        return map;
    }

    public static Collector<String, ?, Map<String, String>> collector() {
        return Collector.of(MappingErrors::new, MappingErrors::accept, MappingErrors::combine, MappingErrors::finish);
    }

}

在这个收集器中，保留了两个正在运行的元素。每次接受字符串时，都会更新它们，如果第一个字符串以“err”开头，则将这两个元素添加到映射中。

Map<String, String> map = 
    StreamEx.of("a", "b", "err1", "c", "d", "err2", "e", "f", "g", "h", "err3", "i", "j")
            .pairMap((s1, s2) -> s1.startsWith("err") ? new String[] { s1, s2 } : null)
            .nonNull()
            .toMap(a -> a[0], a -> a[1]);

System.out.println(map);