pub trait StreamBuffer {
fn new() -> Self;
fn write(&mut self, unparsed_bytes: &[u8]);
fn get(&self) -> &[u8];
fn clear(&mut self, parsed_size: usize);
}
pub struct FlatBuffer {
parsed: usize,
inner: Vec<u8>,
}
impl FlatBuffer {}
impl StreamBuffer for FlatBuffer {
fn new() -> Self {
Self {
parsed: 0,
inner: Vec::new(),
}
}
fn write(&mut self, unparsed_bytes: &[u8]) {
self.inner.extend_from_slice(unparsed_bytes)
}
fn get(&self) -> &[u8] {
&self.inner[self.parsed..]
}
fn clear(&mut self, parsed_size: usize) {
self.parsed += parsed_size;
}
}