Step 3: Testing with StepVerifier complete

mp911de · mp911de · commit 51e65eb0e7ed · 2017-05-07T18:29:58.000+02:00
diff --git a/reactor/src/test/java/workshop/Step3StepVerifier.java b/reactor/src/test/java/workshop/Step3StepVerifier.java
@@ -17,6 +17,7 @@
 
 import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
+import reactor.test.StepVerifier;
 
 import java.time.Duration;
 import java.util.stream.Stream;
@@ -35,30 +36,31 @@ public void verifyMonoEmission() {
 
 		Mono<String> mono = Mono.just("Hello, World").doOnSuccess(System.out::println);
 
-		// Use StepVerifier to verify Mono emission
+		StepVerifier.create(mono).expectNext("Hello, World").verifyComplete();
 	}
 
 	@Test
 	public void verifyFluxEmission() {
 
 		Flux<String> flux = Flux.just("Hello", "World").doOnNext(System.out::println);
 
-		// Use StepVerifier to verify Flux emission
+		StepVerifier.create(flux).expectNext("Hello", "World").verifyComplete();
 	}
 
 	@Test
 	public void verifyInfiniteStreamEmission() {
 
 		Flux<Double> flux = Flux.fromStream(Stream.generate(Math::random)).doOnNext(System.out::println);
 
-		// Use StepVerifier to verify Flux emission
+		StepVerifier.create(flux).expectNextCount(5).thenCancel().verify();
 	}
 
 	@Test
 	public void verifyDelayedEmission() {
 
-		Flux<Long> flux = Flux.interval(Duration.ofSeconds(5)).take(10).doOnNext(System.out::println);
-
-		// Use StepVerifier to verify Flux emission, not spending 5 seconds per emission
+		StepVerifier.withVirtualTime(() -> Flux.interval(Duration.ofSeconds(5)).take(10).doOnNext(System.out::println))
+				.thenAwait(Duration.ofSeconds(50)) //
+				.expectNextCount(10) //
+				.verifyComplete();
 	}
 }
