pub async fn drain_queues(&self) -> Vec<I> {
        let mut events = Vec::new();
        let keys: Vec<K> = self.queues.keys().cloned().collect();

        for kind in keys {
            events.extend(self.drain_queue(kind).await);
        }
        events
    }
/// Drains all events from all queues.
Drains all events from all queues.
Drains all events from all queues .
pub async fn drain_queues(&self) -> Vec<I> {
        let mut events = Vec::new();
        let keys: Vec<K> = self.queues.keys().cloned().collect();
        for kind in keys {
            events.extend(self.drain_queue(kind).await);
        }
        events
    }
pub async fn drain_queues ( & self ) -> Vec < I > { let mut events = Vec :: new ( ) ; let keys : Vec < K > = self . queues . keys ( ) . cloned ( ) . collect ( ) ; for kind in keys { events . extend ( self . drain_queue ( kind ) . await ) ; } events }
Drains all events from all queues.
Drains all events from all queues .
&self
&self