src/error.rs

@@ -20,6 +20,7 @@ impl<B> From<WriteError<B>> for Error<B> {
 
 #[derive(Debug, Clone, Copy, PartialEq, Eq)]
 pub enum ReadError {
+    Truncated { offset: usize },
     InvalidSize { offset: usize, size: usize },
     MissingSeparator { offset: usize },
     Utf8Error(str::Utf8Error),
@@ -28,6 +29,8 @@ pub enum ReadError {
 impl fmt::Display for ReadError {
     fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
         match self {
+            &ReadError::Truncated { offset }=>
+                write!(f, "truncated record at offset {}", offset),
             &ReadError::InvalidSize { offset, size } =>
                 write!(f, "invalid record size {} at offset {}", size, offset),
             &ReadError::MissingSeparator { offset } =>

src/iter.rs

@@ -20,7 +20,7 @@ impl<'a> Iterator for Iter<'a> {
         let data = &self.data[self.offset..];
 
         if data.len() < 4 {
-            return None;
+            return Some(Err(ReadError::Truncated { offset: self.offset }))
         }
 
         let record_size = BigEndian::read_u32(data) as usize;

src/lib.rs

@@ -91,6 +91,13 @@ impl<B: StoreBackend> Store<B> {
     }
 
     fn compact(&mut self) -> Result<(), Error<B::Error>> {
+        // static mut OLD_DATA: B::Data;
+        // let mut old_data = MaybeUninit::<B::Data>::zeroed();
+        // let old_data = unsafe {
+        //     let mut old_data = old_data.assume_init();
+        //     old_data.copy_from_slice(self.backend.data().as_ref());
+        //     old_data
+        // };
         let old_data = self.backend.data().clone();
 
         self.erase()?;