java - 通量:How to test empty Flux

标签 java project-reactor reactive

有没有办法将 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/

相关文章:

angular - 通过formControlName添加CSS类

java - 如何解决: java. lang.NoSuchMethodError : javax. persistence.EntityManager.createStoredProcedureQuery(Ljava/lang/String;)

java - Eclipse 自动显示相同的类名

java - 实例化类字段时捕获异常

java - 比较 JSP 中的日历日期

spring - ReactiveCrudRepository 在 spring 中使用 Hibernate

java - 暂停 kafka 在响应式(Reactive) Kafka 中读取

java - 订阅/迭代 Mono 列表

java - react 堆 : How to convert a Flux of entities into a Flux of DTO objects

r - 如何让 UI 响应 for 循环中的 react 值?