项目Reactor试验从未完成

Question

我创建了一个简单的Kafka使用者，它返回一个对象流（接收到的消息），我试图使用stepverifier测试它。

在我的测试中，我做了类似的事情：

Flux<Pojo> flux = consumer.start();
StepVerifier.create(flux)
  .expectNextMatches(p -> p.getList().size() == 3)
  .verifyComplete();

断言工作正常（如果将值从3更改为其他值，则测试失败）。但是，如果断言通过，测试永远不会退出。

我还尝试使用verify方法，如下所示：

StepVerifier.create(flux)
  .expectNextMatches(f -> f.getEntitlements().size() == 3)
  .expectComplete()
  .verify(Duration.ofSeconds(3));

在本例中，我得到以下错误：

java.lang.AssertionError: VerifySubscriber timed out on false

你知道我做错了什么吗？

Answer 1

Kafkaflux可能是无限的，所以它永远不会发出oncomplete信号，而测试需要等待这个信号。如果只对测试第一个值感兴趣，可以调用.thencancel().verify()。