()
| 137 | |
| 138 | #[tokio::test] |
| 139 | async fn test_equal_query() { |
| 140 | let buf = VecFileWrite::new(); |
| 141 | let mut writer = BTreeIndexWriter::new(Box::new(buf.clone()), 64, BlockCompressionType::None); |
| 142 | |
| 143 | for i in 0..50 { |
| 144 | writer.write(Some(&int_key(i)), i as i64).await.unwrap(); |
| 145 | } |
| 146 | |
| 147 | let result = writer.finish().await.unwrap(); |
| 148 | let reader = write_and_open(&buf, &result, int_cmp).await; |
| 149 | |
| 150 | let bm = reader.query_equal(&int_key(25)).await.unwrap(); |
| 151 | assert_eq!(bm.len(), 1); |
| 152 | assert!(bm.contains(25)); |
| 153 | |
| 154 | let bm = reader.query_equal(&int_key(999)).await.unwrap(); |
| 155 | assert_eq!(bm.len(), 0); |
| 156 | } |
| 157 | |
| 158 | #[tokio::test] |
| 159 | async fn test_range_queries() { |
nothing calls this directly
no test coverage detected