需要帮助为返回流量流作为输出的函数编写junit测试

Question

我需要帮助在编写一个函数的单元测试，这是返回流量流作为输出。

我试过使用步进验证器，但我想我用错了方法。

需要测试以下功能。

public Flux<List<String>> streamCompletedScansAfterLastSubmit(@PathVariable("username") String username) {
    Flux<Long> interval = Flux.interval(Duration.ofSeconds(5));
    Flux<List<String>> completeScans = Flux.fromStream(Stream.generate(() -> scanService.getCompletedScansAfterLastSubmitForUser(username)));
    return Flux.zip(interval, completeScans).map(Tuple2::getT2);
  }

  public void shouldPublishTheAssessmentStatusOnceFinished() {
    when(scanService.getCompletedScansAfterLastSubmitForUser(Mockito.anyString())).thenReturn(Arrays.asList("Scan1:Success"));
    StepVerifier.create(apiScanController.streamCompletedScansAfterLastSubmit("quays_ka"))
      .expectSubscription()
      .expectNext(Arrays.asList("Scan1:Success"))
      .verifyComplete();
  }

不知何故，服务方法会被调用两次（我使用doAnswer检查了这一点）

Answer 1

stream.generate（供应商）生成无限的流，因此completeCans也是无限的。

由于间隔也是无限的，所以对于模拟服务，这两个间隔的压缩会导致流量，它每5秒发出[“scan1:success”]。

相反，您的stepverifier在终止前需要一个非常有限的flux，因此一旦它看到列表的第二次出现，它就会失败。