diff --git a/crates/hyperqueue/src/server/event/journal/read.rs b/crates/hyperqueue/src/server/event/journal/read.rs index 262a3d916..0c1620d6e 100644 --- a/crates/hyperqueue/src/server/event/journal/read.rs +++ b/crates/hyperqueue/src/server/event/journal/read.rs @@ -67,7 +67,7 @@ impl JournalReader { } impl Iterator for &mut JournalReader { - type Item = Result; + type Item = Result; fn next(&mut self) -> Option { self.position = self.source.stream_position().unwrap(); @@ -83,7 +83,10 @@ impl Iterator for &mut JournalReader { self.partial_data_error = true; None } - _ => Some(Err(error)), + _ => Some(Err(anyhow!( + "Load journal event failed at position: {}. Deserialization error: {error:?}", + self.position + ))), }, } }