()
| 296 | |
| 297 | #[tokio::test] |
| 298 | async fn test_zstd_compression() { |
| 299 | let buf = VecFileWrite::new(); |
| 300 | let mut writer = BTreeIndexWriter::new(Box::new(buf.clone()), 64, BlockCompressionType::Zstd); |
| 301 | |
| 302 | for i in 0..100 { |
| 303 | writer.write(Some(&int_key(i)), i as i64).await.unwrap(); |
| 304 | } |
| 305 | |
| 306 | let result = writer.finish().await.unwrap(); |
| 307 | let reader = write_and_open(&buf, &result, int_cmp).await; |
| 308 | |
| 309 | let all = reader.all_non_null_rows().await.unwrap(); |
| 310 | assert_eq!(all.len(), 100); |
| 311 | |
| 312 | let bm = reader.query_equal(&int_key(50)).await.unwrap(); |
| 313 | assert_eq!(bm.len(), 1); |
| 314 | assert!(bm.contains(50)); |
| 315 | } |
| 316 | |
| 317 | #[tokio::test] |
| 318 | async fn test_single_entry() { |
nothing calls this directly
no test coverage detected