使用StepVerifier测试Flux时断言失败：期望4条实际仅1条

阿华AIGC实验室

2026-5-15

问题分析与修复方案

嘿，我一眼就发现了问题的核心——你不小心把传入的Flux<User>给嵌套包装起来了，这直接导致了验证失败！让我一步步给你拆解：

核心错误点

你代码里的Flux.just(flux)是致命问题：这个方法会把传入的Flux<User>对象本身作为单个元素发射出去，最终创建出的是一个Flux<Flux<User>>，而不是你期望的Flux<User>。所以当StepVerifier订阅它时，只会收到1个元素（就是那个嵌套的Flux实例），随后就触发了onComplete()，这完全不符合你要验证4个User元素的需求。

额外的小问题

另外，你这里其实不需要使用withVirtualTime()——这个API是专门用于测试包含延迟、定时操作（比如delayElements、interval）的响应式流的，你的场景是同步发射元素的Flux，用它反而增加了不必要的复杂度。

修正后的代码

下面是两种正确的实现方式：

方式一：基础版（最适合你的场景）

StepVerifier requestAllExpectFour(Flux<User> flux) {
    return StepVerifier.create(flux)
            .expectSubscription()
            .thenRequestAll() // 初始请求所有元素
            .expectNextCount(4)
            .expectComplete();
}

方式二：如果确实需要使用VirtualTime（比如后续要加定时逻辑）

如果你之后要给Flux添加定时操作，需要保留withVirtualTime()，那要注意正确传入要测试的Flux：

StepVerifier requestAllExpectFour(Flux<User> flux) {
    return StepVerifier.withVirtualTime(() -> flux) // 直接返回传入的Flux，不要嵌套包装
            .expectSubscription()
            .thenRequestAll()
            .expectNextCount(4)
            .expectComplete();
}