(&mut self)
| 251 | } |
| 252 | |
| 253 | async fn emit_subscriptions(&mut self) -> WsResult { |
| 254 | let ids = self |
| 255 | .active_log_streams |
| 256 | .iter() |
| 257 | .map(|item| item.guild_id) |
| 258 | .collect::<Vec<_>>(); |
| 259 | |
| 260 | self.send_event(WsEvent::SubscriptionsUpdated(ids)).await |
| 261 | } |
| 262 | |
| 263 | async fn check_guild_acces(&mut self, guild_id: Id<GuildMarker>) -> WsResult { |
| 264 | let session = match &self.state { |
no test coverage detected