Java Stream API 不应被 Mock，正确做法是 Mock 依赖数据源和外部方法，断言终端操作结果。测试应聚焦输入→处理→输出的业务逻辑，而非 Stream 内部流程。
Java Stream API 本身是无状态、惰性求值的函数式抽象，不能也不应该被 Mock。试图 Mock `Stream` 或其中间操作（如 `filter`、`map`）不仅技术上困难（`Stream` 是 final 类，多数方法返回新 Stream），更违背测试原则：你该测的是业务逻辑行为，不是 Stream 的内部执行流程。
✅ 正确思路：Mock 依赖，验证最终输出
Stream 通常是数据处理管道的“胶水”，真正含业务逻辑的是：
- 上游数据源（如 Repository、Service 方法）
- 中间转换中调用的外部方法（如 `UserService::enrichUser`、`PriceCalculator::applyDiscount`）
- 终端操作的结果（如 `collect(toList())` 后的 List、`findFirst()` 的 Optional）
单元测试应聚焦于：给定输入 → 经过被测方法（含 Stream 流程）→ 断言最终结果是否符合预期。Mock 只用于隔离外部依赖，确保测试稳定、快速、可重复。
? 实操：三步写出可靠 Stream 单元测试
1. 提取可测方法
避免在私有方法或长链式 Stream 中混入复杂逻辑。把核心转换逻辑提取为独立方法（最好带明确语义），方便单独测试或 Mock 调用：
public List<OrderDto> getValidOrdersForCustomer(String customerId) {
return orderRepository.findByCustomerId(customerId) // ← Mock 这里
.stream()
.filter(this::isOrderActive) // ← 可单独测这个 boolean 方法
.map(this::toOrderDto) // ← 可 Mock 或直接测这个转换逻辑
.filter(dto -> dto.total() > MIN_VALUE) // ← 简单条件，无需 Mock
.sorted(comparing(OrderDto::date))
.collect(toList());
}
2. Mock 数据源与协作对象
用 Mockito（或 JUnit 5 + MockingStatic）控制输入数据和外部调用：
- Mock `orderRepository.findByCustomerId()` 返回预设的 `List
` - 若 `toOrderDto()` 内部调用了 `userClient.findById()`，则 Mock `userClient` 并返回固定 User
- 避免 Mock `Stream.filter()` 或 `Stream.map()` —— 它们是 JDK 内置行为，可信
3. 断言终端结果，而非流过程
检查最终集合内容，用 AssertJ 提升可读性：
assertThat(result)
.hasSize(2)
.extracting("id", "status", "total")
.containsExactly(
tuple("ORD-001", "SHIPPED", BigDecimal.valueOf(99.9)),
tuple("ORD-003", "PROCESSING", BigDecimal.valueOf(149.9))
);
⚠️ 常见误区与避坑提示
- 不要 Mock Stream.of() 或集合的 stream() 方法 —— 它们只是构造器，返回真实 Stream，Mock 反而让测试变脆
- 别断言 “filter 被调用 5 次” —— 这属于白盒实现细节，重构后易失败；关注“哪些元素留下”才是契约
- 慎用 mocking static（如 MockingStatic<Stream>） —— 极少数场景需控制 `Stream.generate()` 行为时才考虑，日常完全不需要
- 并发流（parallelStream）？ —— 单元测试中一律用普通 stream，避免竞态；并发行为交由集成测试覆盖
? 进阶技巧：测试含副作用的流操作
如果 Stream 中有 `peek(System.out::println)` 或写日志等副作用，可将副作用封装成接口（如 `EventLogger`），然后 Mock 该接口并验证 `logProcessedOrder()` 是否被正确调用（含参数）：
立即学习“Java免费学习笔记（深入）”；
- 定义 `Consumer
logger = eventLogger::log` - 在 Stream 中使用 `.peek(logger)`
- Mock `eventLogger`，用 `verify(eventLogger).log(argThat(...))` 断言
