We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 8403ba8 commit f3ebddeCopy full SHA for f3ebdde
1 file changed
rust/lance-namespace-impls/src/dir.rs
@@ -5772,8 +5772,8 @@ mod tests {
5772
5773
let cursor = Cursor::new(bytes.to_vec());
5774
let reader = StreamReader::try_new(cursor, None).unwrap();
5775
- let total_rows: usize = reader.flatten().map(|b| b.num_rows()).sum();
5776
- assert_eq!(total_rows, 0);
+ let batches: Vec<_> = reader.collect::<std::result::Result<Vec<_>, _>>().unwrap();
+ assert!(batches.is_empty(), "empty table should yield no batches");
5777
}
5778
5779
#[tokio::test]
0 commit comments