Step 2: Improved solution

mp911de · mp911de · commit 072104782363 · 2017-05-07T18:29:57.000+02:00
diff --git a/reactor/src/test/java/workshop/Step2Flux.java b/reactor/src/test/java/workshop/Step2Flux.java
@@ -65,8 +65,7 @@ public void fluxShouldEmitItemsOverTime() {
 
 		Duration duration = Duration.ofSeconds(2);
 
-		Flux<Long> flux = Flux.interval(duration);
-
-		StepVerifier.create(flux.doOnNext(System.out::println).take(4)).expectNext(0L, 1L, 2L, 3L).verifyComplete();
+		StepVerifier.withVirtualTime(() -> Flux.interval(duration).doOnNext(System.out::println).take(4))
+				.thenAwait(Duration.ofSeconds(10)).expectNext(0L, 1L, 2L, 3L).verifyComplete();
 	}
 }

Original file line number	Diff line number	Diff line change
`@@ -65,8 +65,7 @@ public void fluxShouldEmitItemsOverTime() {`
`65`	`65`
`66`	`66`	`Duration duration = Duration.ofSeconds(2);`
`67`	`67`
`68`		`- Flux<Long> flux = Flux.interval(duration);`
`69`		`-`
`70`		`- StepVerifier.create(flux.doOnNext(System.out::println).take(4)).expectNext(0L, 1L, 2L, 3L).verifyComplete();`
	`68`	`+ StepVerifier.withVirtualTime(() -> Flux.interval(duration).doOnNext(System.out::println).take(4))`
	`69`	`+ .thenAwait(Duration.ofSeconds(10)).expectNext(0L, 1L, 2L, 3L).verifyComplete();`
`71`	`70`	`}`
`72`	`71`	`}`