diff options
| author | Paul-Christian Volkmer | 2024-01-15 10:15:36 +0100 |
|---|---|---|
| committer | GitHub | 2024-01-15 10:15:36 +0100 |
| commit | 4bc69a353c5bc758de4979120f611875eb0051de (patch) | |
| tree | 13c3edeaad9608b7fc2da2a8796a2873867cd396 /src/main/kotlin | |
| parent | a1a252d5a95dc161523d1a6740f8439858789a59 (diff) | |
| parent | 9d30f750f722ae460cd1fe5ee8376c8dc44714bb (diff) | |
Merge pull request #26 from CCC-MF/issue_23
feat #23: add reload button to display on new request
Diffstat (limited to 'src/main/kotlin')
| -rw-r--r-- | src/main/kotlin/dev/dnpm/etl/processor/web/StatisticsRestController.kt | 5 |
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() ) ) |