检查java流是否已被使用

Question

一个类似于Iterator中的hasNext()的方法，在异常抛出和布尔返回行为中（尽管没有与Next()的约定）。

示例：

public void consume(java.util.function.Consumer<Stream<?>> consumer, Stream<?> stream) {
   consumer.accept(stream);
   // defensive programming, check state
   if (...) {
       throw new IllegalStateException("consumer must call terminal operation on stream");
   }
}

目标是在客户端代码调用此方法而不消耗流的情况下早期失败。

一个可接受的答案也可以是“没有解决方案存在”，并有充分的理由说明为什么规范不能添加这样的方法（如果有充分的理由的话）。看起来JDK流通常在其终端方法的开头有以下代码段：

// in AbstractPipeline.java
if (linkedOrConsumed)
    throw new IllegalStateException(MSG_STREAM_LINKED);

因此，对于这些流，实现这样的方法似乎并不困难。

Answer 1

考虑到spliterator（例如）是一个终端操作，您可以简单地创建如下方法：

private static <T> Optional<Stream<T>> isConsumed(Stream<T> stream) {

    Spliterator<T> spliterator;
    try {
        spliterator = stream.spliterator();
    } catch (IllegalStateException ise) {
        return Optional.empty();
    }

    return Optional.of(StreamSupport.stream(
        () -> spliterator,
        spliterator.characteristics(),
        stream.isParallel()));
}

我不知道有什么更好的方法...用法为：

Stream<Integer> ints = Stream.of(1, 2, 3, 4)
                                 .filter(x -> x < 3);

YourClass.isConsumed(ints)
         .ifPresent(x -> x.forEachOrdered(System.out::println));

由于我认为没有返回一个已经使用的流的实际理由，所以我将返回optional.empty()。