Trait Queue

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

Required Methods

fn push(&self, bytes: Bytes)

Push one bytes.

fn extend(&self, header: Bytes, body: &[&[Bytes]])

Push multiple bytes atomically

Implementors