pub trait Queue {
    fn push(&self, bytes: Bytes);
    fn extend(&self, header: Bytes, body: &[&[Bytes]]);
}

Required Methods

Push one bytes.

Push multiple bytes atomically

Implementors