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;
16 private final int shard;
18 public Mono<ChatRoom> putChatRoom(ChatRoom chatRoom)
20 return service.putChatRoom(chatRoom);
23 public Mono<ChatRoom> getChatRoom(UUID id)
26 .getChatRoom(shard, id)
27 .switchIfEmpty(Mono.error(() -> new UnknownChatroomException(id)));
30 public Flux<ChatRoom> getChatRooms()
32 return service.getChatRooms(shard);