use {crate::state::State, std::rc::Rc}; pub struct SlowClientHandler { pub state: Rc, } impl SlowClientHandler { pub async fn handle_events(&mut self) { loop { let client = self.state.slow_clients.pop().await; client.check_queue_size().await; } } } pub struct SlowEiClientHandler { pub state: Rc, } impl SlowEiClientHandler { pub async fn handle_events(&mut self) { loop { let client = self.state.slow_ei_clients.pop().await; client.check_queue_size().await; } } }