有没有办法将 ArgumentCapture 用于 Flux?
我想模拟一个在此过程中创建输入参数(flux)的服务:
Flux<A> fluxa = createFluxA();
Flux<B> fluxb = createFluxB()
...
return service.createMono(fluxa,fluxb)
我的单元测试:
AObject aobject = mock(AObject.class);
when(service.createMono(any(), any()).thenReturn(Mono.just(aobject));
...
StepVerifer...
仅当我使用匹配器any()时,单元测试才有效。如果 FluxB 应该是一个空 Flux,我该如何测试它? eq(Flux.empty()) 不起作用,因为 Flux 没有相等的函数
提前致谢
最佳答案
要测试空 Flux,您可以在 Subscription
之后使用 verifyComplete()
。如果 Flux 有元素,则测试将失败
StepVerifier.create(myflux)
.expectSubscription()
.verifyComplete();
您还可以检查expectNextCount(0)
关于java - 通量:How to test empty Flux,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/49168109/