1 package de.juplo.kafka.chat.backend.persistence.inmemory;
3 import de.juplo.kafka.chat.backend.domain.ChatRoom;
4 import reactor.core.publisher.Flux;
5 import reactor.core.publisher.Mono;
10 public interface ChatHomeService
12 Mono<ChatRoom> getChatRoom(int shard, UUID id);
13 Flux<ChatRoom> getChatRooms(int shard);