(&mut self, guild_id: Id<GuildMarker>)
| 240 | } |
| 241 | |
| 242 | async fn unsubscribe_logs(&mut self, guild_id: Id<GuildMarker>) -> WsResult { |
| 243 | let current_streams = std::mem::replace(&mut self.active_log_streams, SelectAll::new()); |
| 244 | |
| 245 | self.active_log_streams = current_streams |
| 246 | .into_iter() |
| 247 | .filter(|e| e.guild_id == guild_id) |
| 248 | .collect(); |
| 249 | |
| 250 | self.emit_subscriptions().await |
| 251 | } |
| 252 | |
| 253 | async fn emit_subscriptions(&mut self) -> WsResult { |
| 254 | let ids = self |
no test coverage detected