diff options
| author | Paul-Christian Volkmer | 2024-05-08 09:18:29 +0200 |
|---|---|---|
| committer | Paul-Christian Volkmer | 2024-05-08 09:18:29 +0200 |
| commit | 52171e8ebef6bc92da0782ad46b47e22904aec84 (patch) | |
| tree | ab850e5e922d385af64c8d34faa438ca75b3804b /src/main/kotlin/dev/dnpm/etl/processor | |
| parent | a2124ba83dc274f7c765b6ed6aba386c5bf3a2a5 (diff) | |
test: add test for config SSE endpoint
Diffstat (limited to 'src/main/kotlin/dev/dnpm/etl/processor')
| -rw-r--r-- | src/main/kotlin/dev/dnpm/etl/processor/web/ConfigController.kt | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/src/main/kotlin/dev/dnpm/etl/processor/web/ConfigController.kt b/src/main/kotlin/dev/dnpm/etl/processor/web/ConfigController.kt index 165535f..25ec7cc 100644 --- a/src/main/kotlin/dev/dnpm/etl/processor/web/ConfigController.kt +++ b/src/main/kotlin/dev/dnpm/etl/processor/web/ConfigController.kt @@ -183,6 +183,7 @@ class ConfigController( } @GetMapping(path = ["events"], produces = [MediaType.TEXT_EVENT_STREAM_VALUE]) + @ResponseBody fun events(): Flux<ServerSentEvent<Any>> { return connectionCheckUpdateProducer.asFlux().map { val event = when (it) { |