1 package de.juplo.kafka.chat.backend.persistence;
3 import de.juplo.kafka.chat.backend.domain.ChatRoom;
4 import de.juplo.kafka.chat.backend.domain.ChatRoomInfo;
5 import reactor.core.publisher.Flux;
8 public interface StorageStrategy
10 void write(Flux<ChatRoomInfo> chatroomFlux);
11 Flux<ChatRoom> read();