summaryrefslogtreecommitdiff
path: root/src/main/kotlin/dev/dnpm
diff options
context:
space:
mode:
authorPaul-Christian Volkmer2024-01-15 09:17:38 +0100
committerPaul-Christian Volkmer2024-01-15 09:17:38 +0100
commit9d30f750f722ae460cd1fe5ee8376c8dc44714bb (patch)
tree13c3edeaad9608b7fc2da2a8796a2873867cd396 /src/main/kotlin/dev/dnpm
parenta1a252d5a95dc161523d1a6740f8439858789a59 (diff)
feat #23: add reload button to display on new request
Diffstat (limited to 'src/main/kotlin/dev/dnpm')
-rw-r--r--src/main/kotlin/dev/dnpm/etl/processor/web/StatisticsRestController.kt5
1 files changed, 5 insertions, 0 deletions
diff --git a/src/main/kotlin/dev/dnpm/etl/processor/web/StatisticsRestController.kt b/src/main/kotlin/dev/dnpm/etl/processor/web/StatisticsRestController.kt
index 6f0e820..546909e 100644
--- a/src/main/kotlin/dev/dnpm/etl/processor/web/StatisticsRestController.kt
+++ b/src/main/kotlin/dev/dnpm/etl/processor/web/StatisticsRestController.kt
@@ -132,6 +132,7 @@ class StatisticsRestController(
@GetMapping(path = ["events"], produces = [MediaType.TEXT_EVENT_STREAM_VALUE])
fun updater(): Flux<ServerSentEvent<Any>> {
return statisticsUpdateProducer.asFlux().flatMap {
+ println(it)
Flux.fromIterable(
listOf(
ServerSentEvent.builder<Any>()
@@ -152,6 +153,10 @@ class StatisticsRestController(
.build(),
ServerSentEvent.builder<Any>()
.event("deleterequestpatientstates").id("none").data(this.requestPatientStates(true))
+ .build(),
+
+ ServerSentEvent.builder<Any>()
+ .event("newrequest").id("none").data("newrequest")
.build()
)
)