Fix

trueleo · trueleo · commit 32086d2b558e · 2023-10-31T12:25:12.000+05:30
diff --git a/server/src/utils/arrow/reverse_reader.rs b/server/src/utils/arrow/reverse_reader.rs
@@ -119,7 +119,7 @@ pub fn get_reverse_reader<T: Read + Seek>(
         .collect();
 
     // reset reader
-    reader.rewind();
+    reader.rewind()?;
 
     Ok(StreamReader::try_new(OffsetReader::new(reader, messages), None).unwrap())
 }

Original file line number	Diff line number	Diff line change
`@@ -119,7 +119,7 @@ pub fn get_reverse_reader<T: Read + Seek>(`
`119`	`119`	`.collect();`
`120`	`120`
`121`	`121`	`// reset reader`
`122`		`- reader.rewind();`
	`122`	`+ reader.rewind()?;`
`123`	`123`
`124`	`124`	`Ok(StreamReader::try_new(OffsetReader::new(reader, messages), None).unwrap())`
`125`	`125`	`}`