aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorJan Tuomi <jan@jantuomi.fi>2025-01-10 15:20:17 +0200
committerJan Tuomi <jan@jantuomi.fi>2025-01-10 19:48:55 +0200
commit07c593d9b836232c2d9bbe986baaa3099edddbb4 (patch)
treea310bf94e6abc706e19014d6e5ea5157a7c16051
parent3ffa6702cdb39c21a26ddc434f46d17d0104cb7b (diff)
Make record iterator call more idiomatic with unwrap_or_else
-rw-r--r--log_db/src/log_reader_forward.rs8
-rw-r--r--log_db/src/log_reader_reverse.rs10
2 files changed, 6 insertions, 12 deletions
diff --git a/log_db/src/log_reader_forward.rs b/log_db/src/log_reader_forward.rs
index 8063918..fc824b2 100644
--- a/log_db/src/log_reader_forward.rs
+++ b/log_db/src/log_reader_forward.rs
@@ -87,11 +87,9 @@ impl Iterator for ForwardLogReader {
type Item = ForwardLogReaderItem;
fn next(&mut self) -> Option<Self::Item> {
- match self.read_record() {
- Ok(Some(record)) => Some(record),
- Ok(None) => None,
- Err(err) => panic!("Error reading record: {:?}", err),
- }
+ self.read_record().unwrap_or_else(|err| {
+ panic!("Error reading record: {:?}", err);
+ })
}
}
diff --git a/log_db/src/log_reader_reverse.rs b/log_db/src/log_reader_reverse.rs
index 0c95322..ef2b0dc 100644
--- a/log_db/src/log_reader_reverse.rs
+++ b/log_db/src/log_reader_reverse.rs
@@ -111,12 +111,8 @@ impl Iterator for ReverseLogReader {
type Item = Record;
fn next(&mut self) -> Option<Self::Item> {
- match self.read_record() {
- Ok(Some(record)) => Some(record),
- Ok(None) => None,
- Err(err) => {
- panic!("Error reading record: {:?}", err)
- }
- }
+ self.read_record().unwrap_or_else(|err| {
+ panic!("Error reading record: {:?}", err);
+ })
}
}