[WebFlux] StepVerifier and How to use it 해답 코드 - techio

techio reactor StepVerifier 학습 사이트

techio에서 배울 수 있는 Reactor StepVerifier 학습 success코드

operator 참고 사이트

StepVerifier reference site

StepVerifier를 이용해 단계별로 체크할 수 있다. 

해답 코드

Verify Simple flux

    // TODO Use StepVerifier to check that the flux parameter emits "foo" and "bar" elements then completes successfully.
    void expectFooBarComplete(Flux flux) {
      StepVerifier.create(flux)
          .expectNext("foo")
          .expectNext("bar")
          .verifyComplete();  
    }

Verify an error

    // TODO Use StepVerifier to check that the flux parameter emits "foo" and "bar" elements then a RuntimeException error.
    void expectFooBarError(Flux flux) {
      StepVerifier.create(flux)
          .expectNext("foo")
          .expectNext("bar")
          .verifyError(RuntimeException.class);
    }

Lambda and assertion

    // TODO Use StepVerifier to check that the flux parameter emits a User with "swhite"username
    // and another one with "jpinkman" then completes successfully.
    void expectSkylerJesseComplete(Flux flux) {
        StepVerifier.create(flux)
            .assertNext( user -> {assertThat(user.getUsername()).isEqualTo("swhite");})
            .assertNext( user -> {assertThat(user.getUsername()).isEqualTo("jpinkman");})
            .verifyComplete();
    }

Wait some time

    // TODO Expect 10 elements then complete and notice how long the test takes.
    void expect10Elements(Flux flux) {
      StepVerifier.create(flux)
          .expectNextCount(10)
          .verifyComplete();
    }

Virtual time

    // TODO Expect 3600 elements at intervals of 1 second, and verify quicker than 3600s
    // by manipulating virtual time thanks to StepVerifier#withVirtualTime, notice how long the test takes
    void expect3600Elements(Supplier<Flux> supplier) {
      StepVerifier.withVirtualTime(supplier)
          .thenAwait(Duration.ofHours(1))
          .expectNextCount(3600)
          .verifyComplete();
    }