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;
12 @RequiredArgsConstructor
15 private final ChatHomeService service;
17 public Mono<ChatRoom> createChatroom(String name)
19 return service.createChatRoom(UUID.randomUUID(), name);
22 public Mono<ChatRoom> getChatRoom(UUID id)
26 .switchIfEmpty(Mono.error(() -> new UnknownChatroomException(id)));
29 public Flux<ChatRoom> getChatRooms()
31 return service.getChatRooms();