(&self, event: &str)
| 171 | } |
| 172 | |
| 173 | pub fn broadcast(&self, event: &str) { |
| 174 | let _ = self.event_bus.send(event.to_string()); |
| 175 | } |
| 176 | |
| 177 | async fn load_sessions_from_storage(&self) -> anyhow::Result<()> { |
| 178 | let (Some(session_repo), Some(message_repo)) = (&self.session_repo, &self.message_repo) |
no test coverage detected