1 package de.juplo.kafka.chat.backend.storage.nostorage;
3 import de.juplo.kafka.chat.backend.domain.ChatRoomInfo;
4 import de.juplo.kafka.chat.backend.domain.Message;
5 import de.juplo.kafka.chat.backend.implementation.StorageStrategy;
6 import reactor.core.publisher.Flux;
11 public class NoStorageStorageStrategy implements StorageStrategy
14 public void writeChatRoomInfo(Flux<ChatRoomInfo> chatRoomInfoFlux) {}
17 public Flux<ChatRoomInfo> readChatRoomInfo()
23 public void writeChatRoomData(UUID chatRoomId, Flux<Message> messageFlux) {}
26 public Flux<Message> readChatRoomData(UUID chatRoomId)