인프런 커뮤니티 질문&답변

안녕하세요! 강의 잘 듣고 있습니다. 다름이아니라

section10.class01.StepVerifierTimeBasedTestExample04 여기서 expectNoEvent 이 오퍼레이터가 시간을 기다려 주는 기능을 한다 이렇게 이해했는데 제가 조금 커스텀해서 찍어보다 보니 작동 방식이 도저히 이해가 되지 않아서 질문 남겼습니다.

아래 코드 처럼 1분마다 emit되는 예제에서 중구, 서초구는 1분씩 기다렸으니 순서대로 나오는게 맞는데 그 다음은 2분을 기다렸으니 강동구가 나와야 할 것 같았는데 강서구가 나오더라고요. expectNoEvent라는 오퍼레이터가 가지는 의미를 어떻게 이해야 할지 도저히 감이 안잡힙니다...ㅠ

[전체코드(테스트성공)]

public class StepVerifierTimeBasedTestExample04 {
    @Test
    public void getCOVID19CountTest() {
        StepVerifier
                .withVirtualTime(() -> TimeBasedExample.getVoteCount(
                                Flux.interval(Duration.ofMinutes(1)) // 1분마다 data를 emit
                        )
                )
                .expectSubscription()
                .expectNoEvent(Duration.ofMinutes(1)) // 1분동안 아무런 이벤트가 발생하지 않음
                .expectNext(Tuples.of("중구", 15400)) // 첫번째 튜플
                .expectNoEvent(Duration.ofMinutes(1))
                .expectNext(Tuples.of("서초구", 20020))
                .expectNoEvent(Duration.ofMinutes(1))
                .expectNoEvent(Duration.ofMinutes(1))
                .expectNext(Tuples.of("강서구", 32040))
                .expectNoEvent(Duration.ofMinutes(1))
                .expectNextCount(2)
                .expectComplete()
                .verify();
    }
}

[getVoteCount 함수]

public static Flux<Tuple2<String, Integer>> getVoteCount(Flux<Long> source) {
    return source
            .zipWith(Flux.just(
                                Tuples.of("중구", 15400),
                                Tuples.of("서초구", 20020),
                                Tuples.of("강서구", 32040),
                                Tuples.of("강동구", 14506),
                                Tuples.of("서대문구", 35650)
                            )
            )
            .map(Tuple2::getT2);
}