- @GetMapping(
- path = "listen/{chatroomId}",
- produces = MediaType.TEXT_EVENT_STREAM_VALUE)
- public Flux<MessageTo> listen(@PathVariable UUID chatroomId)
+ @GetMapping(path = "listen/{chatroomId}")
+ public Flux<ServerSentEvent<MessageTo>> listen(@PathVariable UUID chatroomId)
+ {
+ return chatHome
+ .getChatroom(chatroomId)
+ .map(chatroom -> listen(chatroom))
+ .orElseThrow(() -> new UnknownChatroomException(chatroomId));
+ }
+
+ private Flux<ServerSentEvent<MessageTo>> listen(Chatroom chatroom)