1 package de.juplo.kafka.chat.backend.persistence.storage.files;
3 import de.juplo.kafka.chat.backend.domain.ChatRoomService;
4 import de.juplo.kafka.chat.backend.domain.Message;
5 import reactor.core.publisher.Flux;
8 public interface ChatRoomServiceFactory
10 ChatRoomService create(Flux<Message> messageFlux);