diff --git a/main-app/src/main/java/demo/client/Step3a.java b/main-app/src/main/java/demo/client/Step3a.java
index f08deba..2e297ca 100644
--- a/main-app/src/main/java/demo/client/Step3a.java
+++ b/main-app/src/main/java/demo/client/Step3a.java
@@ -11,7 +11,7 @@ public class Step3a {
 
 	public static void main(String[] args) {
 
-		client.get().uri("/persons/stream")
+		client.get().uri("/persons/events")
 				.retrieve()
 				.bodyToFlux(Person.class)
 				.take(4)
diff --git a/remote-services/src/main/java/demo/RemoteServicesApp.java b/remote-services/src/main/java/demo/RemoteServicesApp.java
index cc7b85f..3e16e35 100644
--- a/remote-services/src/main/java/demo/RemoteServicesApp.java
+++ b/remote-services/src/main/java/demo/RemoteServicesApp.java
@@ -48,7 +48,8 @@ public RouterFunction<?> routes() {
 				})
 				.GET("/persons/events", request -> {
 					Flux<ServerSentEvent<Map<String, Object>>> stream =
-							Flux.interval(Duration.ofSeconds(2))
+							Flux.interval(Duration.ofSeconds(2), Duration.ofSeconds(1))
+									.take(12)
 									.map(i -> PERSON_DATA.get((i % 10) + 1))
 									.map(data -> ServerSentEvent.builder(data).build());
 					return ServerResponse.ok().body(fromServerSentEvents(stream));