为什么 StepVerifer 虚拟时间不适用于 Flux？

Question

我一直在使用 lite-rx-api-hands-on 教程来尝试了解 reactor，我对其中一个测试的结果感到有点困惑，使用 StepVerifier 尝试虚拟时间。

这非常有效：

@Test
public void expect10Elements() {
    StepVerifier.withVirtualTime(() -> Flux.interval(Duration.ofSeconds(1)).take(10))
                .thenAwait(Duration.ofSeconds(10))
                .expectNextCount(10)
                .expectComplete()
                .verify();
}

但这行不通

@Test
public void expect10Elements() {
    Flux<Long> flux = Flux.interval(Duration.ofSeconds(1)).take(10);

    StepVerifier.withVirtualTime(() -> flux)
                .thenAwait(Duration.ofSeconds(10))
                .expectNextCount(10)
                .expectComplete()
                .verify();
}

如果我在发布者中发布通量之前没有订阅通量，我不太明白为什么会发生这种情况。有人可以帮忙吗？

Answer 1

这是因为虚拟时间的实现方式。

解释见Reactor Reference:

This virtual time feature plugs in a custom Scheduler in Reactor’s Schedulers factory. Since these timed operators usually use the default Schedulers.parallel() scheduler, replacing it with a VirtualTimeScheduler does the trick. However, an important prerequisite is that the operator be instantiated after the virtual time scheduler has been activated.

To increase the chances that this happens correctly, the StepVerifier does not take a simple Flux as input. withVirtualTime takes a Supplier, which guides you into lazily creating the instance of the tested flux after having done the scheduler set up.

Take extra care to ensure the Supplier<Publisher<T>> can be used in a lazy fashion. Otherwise, virtual time is not guaranteed. Especially avoid instantiating the Flux earlier in the test code and having the Supplier return that variable. Instead, always instantiate the Flux inside the lambda.

为什么 StepVerifer 虚拟时间不适用于 Flux？

Why StepVerifer virtual time not works on Flux?

java

project-reactor