From 12cd1bdd4bb3e6140d144d4b8451d5d13e057a2e Mon Sep 17 00:00:00 2001 From: Tangent 128 Date: Mon, 2 Apr 2018 20:11:54 -0400 Subject: [PATCH] Debugging formatting --- src/chunk.rs | 2 +- src/webm_stream.rs | 8 +++++++- 2 files changed, 8 insertions(+), 2 deletions(-) diff --git a/src/chunk.rs b/src/chunk.rs index 3c10b09..449248b 100644 --- a/src/chunk.rs +++ b/src/chunk.rs @@ -50,7 +50,7 @@ impl AsRef<[u8]> for ClusterHead { } } -#[derive(Clone)] +#[derive(Clone, Debug)] pub enum Chunk = Vec> { Headers { bytes: Arc diff --git a/src/webm_stream.rs b/src/webm_stream.rs index 8d3ee45..d2a77b9 100644 --- a/src/webm_stream.rs +++ b/src/webm_stream.rs @@ -28,12 +28,17 @@ impl, S: Stream> WebmBuffer { pub fn try_decode(&mut self) -> Result>, ParsingError> { match WebmElement::decode_element(&self.buffer) { - Err(err) => return Err(ParsingError::EbmlError(err)), + Err(err) => { + //println!("EBML error: {:?}", err); + return Err(ParsingError::EbmlError(err)) + }, Ok(None) => { + //println!("Need refill"); // need to refill buffer return Ok(Async::NotReady); }, Ok(Some((element, element_size))) => { + //println!("Parsed element: {:?}", element); self.last_read = element_size; return Ok(Async::Ready(Some(element))) } @@ -63,6 +68,7 @@ impl, S: Stream> WebmBuffer { Ok(Async::Ready(Some(chunk))) => { self.buffer.reserve(chunk.as_ref().len()); self.buffer.put_slice(chunk.as_ref()); + //println!("Read {} into Buffer", chunk.as_ref().len()); // ok can retry decoding now } Err(err) => return Err(ParsingError::OtherError(err))