import de.juplo.kafka.chat.backend.domain.ChatRoomData;
import de.juplo.kafka.chat.backend.persistence.StorageStrategy;
import lombok.RequiredArgsConstructor;
import de.juplo.kafka.chat.backend.domain.ChatRoomData;
import de.juplo.kafka.chat.backend.persistence.StorageStrategy;
import lombok.RequiredArgsConstructor;
.createChatRoom(chatRoomId, name)
.map(ChatRoomInfoTo::from);
}
.createChatRoom(chatRoomId, name)
.map(ChatRoomInfoTo::from);
}
.getChatRoomData(chatRoomId)
.flatMap(chatRoomData -> put(chatRoomData, username, messageId, text));
}
.getChatRoomData(chatRoomId)
.flatMap(chatRoomData -> put(chatRoomData, username, messageId, text));
}
.getChatRoomData(chatRoomId)
.flatMap(chatRoomData -> get(chatRoomData, username, messageId));
}
.getChatRoomData(chatRoomId)
.flatMap(chatRoomData -> get(chatRoomData, username, messageId));
}
@GetMapping(path = "{chatRoomId}/listen")
public Flux<ServerSentEvent<MessageTo>> listen(@PathVariable UUID chatRoomId)
{
@GetMapping(path = "{chatRoomId}/listen")
public Flux<ServerSentEvent<MessageTo>> listen(@PathVariable UUID chatRoomId)
{