mono.elapse不能与stepverifier一起工作？

Question

根据它的Javadoc，mono.elapse()将生成mono > ，其中的第一个值是subscribe和第一个next信号之间的经过时间。

以下测试不起作用

StepVerifier.withVirtualTime(() -> Mono.just(1)
                                   .delaySubscription(Duration.ofSeconds(1))
                                   .elapsed(),
            () -> VirtualTimeScheduler.enable(true), 1)
                .thenAwait(Duration.ofSeconds(1))
                .expectNextMatches(tuple2 -> tuple2.getT1() >= 1000 && tuple2.getT2() == 1)
                .verifyComplete();

它将抛出异常：

java.lang.AssertionError: expectation "expectNextMatches" failed (predicate failed on value: 11,1)

我原以为经过的时间至少是1000ms，但结果只有11ms。

Answer 1

elapsed()运算符实际上使用一个基础的timedscheduler来获取时钟“instants”以计算时间增量，因此当使用with virtualtime时，基础的调度程序应该是virtualtimescheduler...

但是有一个bug：当使用默认的调度器时，这样的运算符实际上获得了缓存在包装器中的公共实例。问题是包装器没有委托其now方法，而elapsed使用的方法就是这个方法。

由于now()的默认实现是使用system.CurrentTimeMillis()，因此您实际上看到的是经过的内容将绕过虚拟时间并报告实时差值。

为了解决这个问题，在修复bug之前，您可以显式地创建并提供VirtualTimeScheduler，如下所示：

@Test
public void elapsedWithVirtualTimeWorkaround() {
    //we have to create a reference that will be used in 2 places
    VirtualTimeScheduler vts = VirtualTimeScheduler.create();

    StepVerifier.withVirtualTime(() -> Mono.just(1)
                                           .delaySubscription(Duration.ofSeconds(1))
                                           .elapsed(vts), //this avoids the cache problem
            () -> vts, //the supplied scheduler here will be automatically activated by StepVerifier
            1)
                .thenAwait(Duration.ofSeconds(1)) //this uses the same vts once again
                .expectNextMatches(tuple2 -> tuple2.getT1() >= 1000 && tuple2.getT2() == 1)
                .verifyComplete();
}