From 167b079e29a004c9d5690baf5612e5477e9aeb9c Mon Sep 17 00:00:00 2001 From: Rob Walker Date: Mon, 30 Jul 2018 10:22:35 -0700 Subject: [PATCH] fixups --- src/entry_writer.rs | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) diff --git a/src/entry_writer.rs b/src/entry_writer.rs index 545d23281d..4821cf0d86 100644 --- a/src/entry_writer.rs +++ b/src/entry_writer.rs @@ -27,7 +27,6 @@ impl<'a, W: Write> EntryWriter<'a, W> { .map_err(|e| Error::new(ErrorKind::Other, e.to_string()))?; writer.write_all(&entry_bytes[..])?; - writer.flush() } @@ -60,10 +59,10 @@ impl<'a, W: Write> EntryWriter<'a, W> { struct EntryReader { reader: R, entry_bytes: Vec, - len_len: u64, + len_len: usize, } -impl Iterator for EntryReader { +impl Iterator for EntryReader { type Item = io::Result; fn next(&mut self) -> Option> { @@ -77,7 +76,7 @@ impl Iterator for EntryReader { entry_len = bincode::deserialize(&entry_len_bytes).unwrap(); if entry_len > self.entry_bytes.len() { - self.entry_bytes.resize(entry_len); + self.entry_bytes.resize(entry_len, 0); } if let Err(e) = self.reader.read_exact(&mut self.entry_bytes[..entry_len]) { @@ -99,7 +98,7 @@ pub fn read_entries(reader: R) -> impl Iterator