1 2 3 4 5 6 7 8 9
use bytes::Bytes; pub trait Queue { /// Push one `bytes`. fn push(&self, bytes: Bytes); /// Push multiple bytes atomically fn extend(&self, header: Bytes, body: &[&[Bytes]]); }