如何让Stream.allMatch()在流为空时返回false？

需求与现有代码 #

我希望使用Stream.allMatch()，但需要在流为空时返回false。现有测试代码如下：

public static void main (String[] args) throws java.lang.Exception
{
   System.out.println(testMethod(Stream.empty())); // 期望返回false（实际返回true）
   System.out.println(testMethod(Stream.of("match", "match"))); // 期望返回true
   System.out.println(testMethod(Stream.of("match", "no match"))); // 期望返回false
}
    
private static boolean testMethod(Stream<String> stream) {
   return stream.allMatch(text -> "match".equals(text));
}

测试用例期望结果：

• 空流调用testMethod：返回false（当前实际返回true）
• 所有元素匹配的流：返回true
• 存在不匹配元素的流：返回false

限制条件 #

我不想使用以下方式，因为需要保留Java 8流的短路特性：

• .toList()：会遍历所有元素，失去短路能力
• .reduce()：同样无法保留短路特性

失败的尝试 #

我猜测可以用noMatch()实现，但逻辑错误，结果不符合预期：

private static boolean testMethod(Stream<String> stream) {
   // 尝试的错误实现，结果不正确
   return !stream.noneMatch(text -> !"match".equals(text));
}

注：这并非List场景的重复问题，我使用的是Stream而非List。

业务背景（X-Y问题说明） #

实际业务是用户下载状态指示器的展示逻辑：
我有一张downloads表，结构如下：

由于项目规模庞大，无法修改表结构或进行大规模重构。需求是：仅当用户所有下载状态为ready时显示指示器；若用户暂无下载，则不显示。现有仓库方法为Stream<Downloads> getDownloadsForUser()，短路特性对降低数据库查询和数据处理负载至关重要。

解决方案 #

方案1：使用AtomicBoolean标记元素存在性 #

通过AtomicBoolean记录流中是否有元素，结合allMatch()实现需求，同时保留短路特性：

import java.util.concurrent.atomic.AtomicBoolean;
import java.util.stream.Stream;

public class Test {
    public static void main (String[] args) throws java.lang.Exception
    {
       System.out.println(testMethod(Stream.empty())); // 返回false
       System.out.println(testMethod(Stream.of("match", "match"))); // 返回true
       System.out.println(testMethod(Stream.of("match", "no match"))); // 返回false
    }
        
    private static boolean testMethod(Stream<String> stream) {
       AtomicBoolean hasElement = new AtomicBoolean(false);
       boolean allMatch = stream.allMatch(text -> {
           hasElement.set(true);
           return "match".equals(text);
       });
       return hasElement.get() && allMatch;
    }
}

逻辑说明：

1. AtomicBoolean用于标记流中是否存在至少一个元素，在allMatch的断言逻辑中设置该标记
2. allMatch()本身保留短路特性：一旦遇到不匹配的元素，会立即终止遍历，不会处理后续元素
3. 最终返回hasElement.get() && allMatch：只有当流有元素且所有元素都匹配时返回true；空流时hasElement为false，直接返回false

方案2：使用Spliterator拆分流处理 #

通过Spliterator先判断流是否有元素，再对剩余元素执行allMatch()，同样保留短路特性：

import java.util.Spliterator;
import java.util.stream.Stream;
import java.util.stream.StreamSupport;

public class Test {
    public static void main (String[] args) throws java.lang.Exception
    {
       System.out.println(testMethod(Stream.empty())); // 返回false
       System.out.println(testMethod(Stream.of("match", "match"))); // 返回true
       System.out.println(testMethod(Stream.of("match", "no match"))); // 返回false
    }
        
    private static boolean testMethod(Stream<String> stream) {
       Spliterator<String> spliterator = stream.spliterator();
       // 尝试获取第一个元素，判断流是否为空
       boolean hasElements = spliterator.tryAdvance(t -> {});
       if (!hasElements) {
           return false;
       }
       // 将剩余元素转为流，执行allMatch
       return StreamSupport.stream(spliterator, false)
                           .allMatch(text -> "match".equals(text));
    }
}

逻辑说明：

1. spliterator.tryAdvance(t -> {})尝试获取流的第一个元素，若返回false则说明流为空，直接返回false
2. 若流不为空，将剩余元素转为新流执行allMatch()，保留短路特性
3. 这种方式避免了使用原子类，同样不会遍历所有不必要的元素

内容的提问来源于stack exchange，提问作者akop