pub(crate) async fn push(&self, item: I, queue: K) {
        if self.sealed.load(Ordering::SeqCst) {
            debug!("queue sealed, dropping item");
            return;
        }

        self.queues
            .get(&queue)
            .expect("tried to push to non-existent queue")
            .push_back(item)
            .await;

        // We increase the item count after we've put the item into the queue.
        self.total.add_permits(1);
    }
/// Pushes an item to a queue identified by key.
///
/// ## Panics
///
/// Panics if the queue identified by key `queue` does not exist.
Pushes an item to a queue identified by key.
Pushes an item to a queue identified by key .
pub(crate) async fn push(&self, item: I, queue: K) {
        if self.sealed.load(Ordering::SeqCst) {
            debug!("queue sealed, dropping item");
            return;
        }
        self.queues
            .get(&queue)
            .expect("tried to push to non-existent queue")
            .push_back(item)
            .await;
        // We increase the item count after we've put the item into the queue.
        self.total.add_permits(1);
    }
pub ( crate ) async fn push ( & self , item : I , queue : K ) { if self . sealed . load ( Ordering :: SeqCst ) { debug ! ( " " ) ; return ; } self . queues . get ( & queue ) . expect ( " " ) . push_back ( item ) . await ; // We increase the item count after we've put the item into the queue. self . total . add_permits ( 1 ) ; }
Pushes an item to a queue identified by key.
Pushes an item to a queue identified by key .
&self
item
I
queue
K
&self
item
I
queue
K
panics
Panics if the queue identified by key `queue` does not exist.
Panics if the queue identified by key ` queue ` does not exist .