pub fn remove_batches(&mut self, batch_ids: &[&str]) {
        self.batches
            .retain(|batch| !batch_ids.contains(&batch.batch().header_signature()));
        for id in batch_ids {
            self.ids.remove(*id);
        }
        gauge!(PENDING_BATCH_GAUGE, self.batches.len() as i64);
    }
/// Removes batches with the given IDs from the queue
///
/// Any batches that don't exist in the queue will be ignored.
Removes batches with the given IDs from the queue
Any batches that don't exist in the queue will be ignored.
Removes batches with the given IDs from the queue Any batches that don ' t exist in the queue will be ignored .
pub fn remove_batches(&mut self, batch_ids: &[&str]) {
        self.batches
            .retain(|batch| !batch_ids.contains(&batch.batch().header_signature()));
        for id in batch_ids {
            self.ids.remove(*id);
        }
        gauge!(PENDING_BATCH_GAUGE, self.batches.len() as i64);
    }
pub fn remove_batches ( & mut self , batch_ids : & [ & str ] ) { self . batches . retain ( | batch | ! batch_ids . contains ( & batch . batch ( ) . header_signature ( ) ) ) ; for id in batch_ids { self . ids . remove ( * id ) ; } gauge ! ( PENDING_BATCH_GAUGE self batches len ( ) as i64 ) ; }
Removes batches with the given IDs from the queue
Any batches that don't exist in the queue will be ignored.
Removes batches with the given IDs from the queue Any batches that don ' t exist in the queue will be ignored .
&mut self
batch_ids
&[&str]
&mut self
batch_ids
&[&str]