1 package de.juplo.kafka.chat.backend.domain;
3 import lombok.RequiredArgsConstructor;
4 import lombok.extern.slf4j.Slf4j;
5 import reactor.core.publisher.Flux;
6 import reactor.core.publisher.Mono;
11 @RequiredArgsConstructor
15 private final ChatHomeService service;
18 public Mono<ChatRoom> getChatRoom(UUID id)
22 .switchIfEmpty(Mono.error(() -> new UnknownChatroomException(id)));
25 public Flux<ChatRoom> getChatRooms()
27 return service.getChatRooms();