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
13 public class SimpleChatHome implements ChatHome
15 private final ChatHomeService service;
16 private final int shard;
19 public SimpleChatHome(ChatHomeService service)
26 public Mono<ChatRoom> putChatRoom(ChatRoom chatRoom)
28 return service.putChatRoom(chatRoom);
32 public Mono<ChatRoom> getChatRoom(UUID id)
35 .getChatRoom(shard, id)
36 .switchIfEmpty(Mono.error(() -> new UnknownChatroomException(id)));
40 public Flux<ChatRoom> getChatRooms()
42 return service.getChatRooms(shard);