(&self, room: &String, message: Message)
| 17 | |
| 18 | impl MessageStore { |
| 19 | pub async fn insert(&self, room: &String, message: Message) { |
| 20 | let mut binding = self.messages.write().await; |
| 21 | let messages = binding.entry(room.clone()).or_default(); |
| 22 | messages.push_front(message); |
| 23 | messages.truncate(20); |
| 24 | } |
| 25 | |
| 26 | pub async fn get(&self, room: &String) -> Vec<Message> { |
| 27 | let messages = self.messages.read().await.get(room).cloned(); |