Reactor StepVerifier.withVirtualTime блокируется на неопределенный срок

Я пытаюсь использовать функцию виртуального времени Reactor, но тест блокируется на неопределенный срок (без таймаута) или выдает AssertionError (с таймаутом):

@Test
public void test() {
    StepVerifier.withVirtualTime(() -> 
            Flux.just(1, 2, 3, 4).delayElements(Duration.ofSeconds(1)))
            .expectSubscription()
            .expectNextCount(4)
            .expectComplete()
            .verify(Duration.ofSeconds(10));
}

Исключение составляет:

java.lang.AssertionError: VerifySubscribertimed out on reactor.core.publisher.FluxConcatMap$ConcatMapImmediate@66d1af89

Тот же пример с реальным временем работает так, как ожидалось:

@Test
public void test2() {
    StepVerifier.create(Flux.just(1, 2, 3, 4).delayElements(Duration.ofSeconds(1)))
            .expectSubscription()
            .expectNextCount(4)
            .expectComplete()
            .verify(Duration.ofSeconds(10));
}

Я не вижу ошибки в своем первом примере после манипулирования временем из ссылка.

Что случилось?


java project-reactor
person deamon    schedule 24.08.2017    source источник

Ответы (1)


arrow_upward
10
arrow_downward

Вам нужно использовать .thenAwait(Duration), иначе (виртуальные) часы не будут двигаться, и задержки никогда не будет. Вы также можете использовать .expectNoEvent(Duration) после expectSubscription().

Например:

@Test
public void test() {
  StepVerifier.withVirtualTime(() -> 
        Flux.just(1, 2, 3, 4).delayElements(Duration.ofSeconds(1)))
        .expectSubscription() //t == 0
//move the clock forward by 1s, and check nothing is emitted in the meantime
        .expectNoEvent(Duration.ofSeconds(1))
//so this effectively verifies the first value is delayed by 1s:
        .expectNext(1)
//and so on...
        .expectNoEvent(Duration.ofSeconds(1))
        .expectNext(2)
//or move the clock forward by 2s, allowing events to take place,
//and check last 2 values where delayed
        .thenAwait(Duration.ofSeconds(2))
        .expectNext(3, 4)
        .expectComplete()
//trigger the verification and check that in realtime it ran in under 200ms
        .verify(Duration.ofMillis(200));
}
person Simon Baslé    schedule 24.08.2017