#[derive(Default,Debug,Clone)]
pub struct FrameQueueBuf {
- queue: QueueBuf<Cervine<'static, Box<[u8]>, [u8]>>,
+ queue: QueueBuf<QueuedBytes>,
}
+pub type QueuedBytes = Cervine<'static, Box<[u8]>, [u8]>;
+use Cervine::Owned as QueuedBytesOwned;
+use Cervine::Borrowed as QueuedBytesBorrowed;
+
impl<E> Debug for QueueBuf<E> where E: AsRef<[u8]> {
#[throws(fmt::Error)]
fn fmt(&self, f: &mut fmt::Formatter) {
self.push_esc_(b.into());
}
fn push_esc_(&mut self, b: Box<[u8]>) {
- self.queue.push_(Cervine::Owned(b));
- self.queue.push_(Cervine::Borrowed(&SLIP_END_SLICE));
+ self.queue.push_( QueuedBytesOwned(b));
+ self.queue.push_(QueuedBytesBorrowed(&SLIP_END_SLICE));
}
pub fn esc_push(&mut self, b: Box<[u8]>) {
- self.queue.push_(Cervine::Borrowed(&SLIP_END_SLICE));
- self.queue.push_(Cervine::Owned(b));
+ self.queue.push_(QueuedBytesBorrowed(&SLIP_END_SLICE));
+ self.queue.push_(QueuedBytesOwned(b));
}
pub fn push_raw(&mut self, b: Box<[u8]>) {
- self.queue.push_(Cervine::Owned(b));
+ self.queue.push_(QueuedBytesOwned(b));
}
pub fn is_empty(&self) -> bool { self.queue.is_empty() }
pub fn len(&self) -> usize { self.queue.len() }