pub(super) fn filter_messages<F>(&mut self, filter: F)
    where
        F: FnMut(&Arc<Ingress>) -> bool,
    {
        self.queue.retain(filter);
        self.size_bytes = Self::size_bytes(&self.queue)
    }
/// Calls `filter` on each ingress message in the queue, retaining the
/// messages for whom the filter returns `true` and dropping the rest.
Calls `filter` on each ingress message in the queue, retaining the
messages for whom the filter returns `true` and dropping the rest.
Calls ` filter ` on each ingress message in the queue retaining the messages for whom the filter returns ` true ` and dropping the rest .
pub(super) fn filter_messages<F>(&mut self, filter: F)
    where
        F: FnMut(&Arc<Ingress>) -> bool,
    {
        self.queue.retain(filter);
        self.size_bytes = Self::size_bytes(&self.queue)
    }
pub ( super ) fn filter_messages < F > ( & mut self , filter : F ) where F : FnMut ( & Arc < Ingress > ) -> bool , { self . queue . retain ( filter ) ; self . size_bytes = Self :: size_bytes ( & self . queue ) }
Calls `filter` on each ingress message in the queue, retaining the
messages for whom the filter returns `true` and dropping the rest.
Calls ` filter ` on each ingress message in the queue retaining the messages for whom the filter returns ` true ` and dropping the rest .
&mut self
filter
F
&mut self
filter
F