import java.util.*;
-@Slf4j
@RequiredArgsConstructor
+@Slf4j
public class ChatHome
{
private final ChatHomeService service;
- private final int shard;
- public Mono<ChatRoom> putChatRoom(ChatRoom chatRoom)
- {
- return service.putChatRoom(chatRoom);
- }
public Mono<ChatRoom> getChatRoom(UUID id)
{
return service
- .getChatRoom(shard, id)
+ .getChatRoom(id)
.switchIfEmpty(Mono.error(() -> new UnknownChatroomException(id)));
}
public Flux<ChatRoom> getChatRooms()
{
- return service.getChatRooms(shard);
+ return service.getChatRooms();
}
}