Method check_queue_start_worker

components/scheduler/src/scheduler.rs:127–162

(&mut self, guild_id: Id<GuildMarker>)

    }

    async fn check_queue_start_worker(&mut self, guild_id: Id<GuildMarker>) {
        if let Some(index) = self.pending_starts.iter().position(|v| *v == guild_id) {
            self.pending_starts.remove(index);
            self.get_or_start_guild(guild_id);
        }

        // god i wish drain_filter was stable
        let mut indexes = self
            .queued_events
            .iter()
            .enumerate()
            .filter_map(|(i, v)| {
                if v.guild_id == guild_id {
                    Some(i)
                } else {
                    None
                }
            })
            .collect::<Vec<_>>();

        // reverse to avoid invalidating indexes as we remove their items
        indexes.reverse();

        let mut evts = indexes
            .into_iter()
            .map(|i| self.queued_events.remove(i))
            .collect::<Vec<_>>();

        // reverse back in the proper order
        evts.reverse();

        for evt in evts {
            self.send_or_queue_broker_evt(evt);
            // self.handle_broker_evt(evt).await;
        }
    }

    fn handle_guild_handler_event(&mut self, guild_id: Id<GuildMarker>, event: VmSessionEvent) {
        match event {