From fe6651db3618345f08568f74e939748024c2794a Mon Sep 17 00:00:00 2001 From: Ian Jackson Date: Sat, 11 Jul 2020 23:52:21 +0100 Subject: [PATCH] debugread to its own file --- src/debugreader.rs | 14 ++++++++++++++ src/sse.rs | 14 -------------- 2 files changed, 14 insertions(+), 14 deletions(-) create mode 100644 src/debugreader.rs diff --git a/src/debugreader.rs b/src/debugreader.rs new file mode 100644 index 00000000..bb905074 --- /dev/null +++ b/src/debugreader.rs @@ -0,0 +1,14 @@ +#[derive(Debug)] +pub struct DebugReader(pub T); + +impl Read for DebugReader { + fn read(&mut self, buf: &mut [u8]) -> Result { + let l = buf.len(); + eprintln!("DebugReader({:?}).read()...", l); + let r = self.0.read(buf); + eprintln!("DebugReader({:?}).read() = {:?} {:?}", l, &r, + r.as_ref().map(|&r| str::from_utf8(&buf[0..r]))); + r + } +} + diff --git a/src/sse.rs b/src/sse.rs index 0b566389..71d539ca 100644 --- a/src/sse.rs +++ b/src/sse.rs @@ -148,20 +148,6 @@ impl Read for UpdateReader { } } -#[derive(Debug)] -pub struct DebugReader(pub T); - -impl Read for DebugReader { - fn read(&mut self, buf: &mut [u8]) -> Result { - let l = buf.len(); - eprintln!("DebugReader({:?}).read()...", l); - let r = self.0.read(buf); - eprintln!("DebugReader({:?}).read() = {:?} {:?}", l, &r, - r.as_ref().map(|&r| str::from_utf8(&buf[0..r]))); - r - } -} - #[throws(OE)] pub fn content(iad : InstanceAccessDetails, gen: Generation) -> impl Read { -- 2.30.2