(&mut self)
| 203 | type Item = Result<WalRecord>; |
| 204 | |
| 205 | fn next(&mut self) -> Option<Self::Item> { |
| 206 | match self.reader.next_record() { |
| 207 | Ok(Some(record)) => Some(Ok(record)), |
| 208 | Ok(None) => None, |
| 209 | Err(e) => Some(Err(e)), |
| 210 | } |
| 211 | } |
| 212 | } |
| 213 | |
| 214 | #[cfg(test)] |