From 11777c5caebfdbfd7b3adc84433d731de2680305 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Simon=20Basl=C3=A9?= Date: Mon, 8 Oct 2018 18:44:46 +0100 Subject: [PATCH 1/2] fix the url to the SSE backend endpoint --- main-app/src/main/java/demo/client/Step3a.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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) From 03e4424e7e38a16154bd61d005c60a9e395d662f Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Simon=20Basl=C3=A9?= Date: Tue, 9 Oct 2018 10:56:40 +0100 Subject: [PATCH 2/2] limit the repetition of the SSE to 12 items and have them produced faster --- remote-services/src/main/java/demo/RemoteServicesApp.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) 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>> 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));