package de.juplo.kafka.chat.backend.persistence;
import de.juplo.kafka.chat.backend.domain.ChatRoom;
+import de.juplo.kafka.chat.backend.domain.ChatRoomInfo;
import reactor.core.publisher.Flux;
public interface StorageStrategy
{
- void write(Flux<ChatRoom> chatroomFlux);
+ void write(Flux<ChatRoomInfo> chatroomFlux);
Flux<ChatRoom> read();
}