Java 8 lambda : iterate over stream objects and use previous/next object(s) in stream

Question

我正在练习一些入门级的 java 8 lambda 功能。

给定一个消息列表，每个消息都包含一个消息偏移量，其中所有偏移量必须形成一个连续的整数列表，我试图找到要警告的间隙。我觉得这一切都应该用一个不错的 lambda 来完成。但我无法理解它。

所以，有这个工作片段:

private void warnAboutMessageGaps(final List<Message> messages) {

    final List<Long> offsets = messages.stream()
            .sorted(comparingLong(Message::getOffset))
            .map(Message::getOffset)
            .collect(toList())
            ;

    for (int i = 0; i < offsets.size() - 1; i++) {
        final long currentOffset = offsets.get(i);
        final long expectedNextOffset = offsets.get(i) + 1;
        final long actualNextOffset = offsets.get(i + 1);
        if (currentOffset != expectedNextOffset) {
            LOG.error("Missing offset(s) found in messages: missing from {} to {}", currentOffset + 1, actualNextOffset - 1);
        }
    }
}

我想不通的是如何制作它以便我可以在 lambda 中执行“与上一个/下一个对象比较”。任何指针将不胜感激。

/edit:关于 StreamEx 和其他第三方解决方案的建议虽然值得赞赏，但并不是我想要的。

Answer 1

您可以使用 StreamEx 来完成使用 pairMap 方法:

StreamEx.of(messages)
        .sorted(Comparator.comparingLong(Message::getOffset))
        .pairMap((prev, next) -> new Message[] {prev, next})
        .forEach(prevNext -> {
            long currentOffset = prevNext[0].getOffset();
            long expectedNextOffset = prevNext[0].getOffset() + 1;
            long actualNextOffset = prevNext[1].getOffset();
            if (currentOffset != expectedNextOffset) {
                LOG.error(
                    "Missing offset(s) found in messages: missing from {} to {}",
                    currentOffset + 1, actualNextOffset - 1);
            }
        });