+2 -2

constellation/src/storage/mem_store.rs

··· 288 288 .enumerate() 289 289 .filter_map(|(i, opt)| opt.as_ref().map(|v| (i, v))) 290 290 .skip_while(|(linker_idx, _)| cursor.is_some_and(|c| *linker_idx < c.backward as usize)) 291 291 - .filter(|(_, (did, _))| filter_dids.is_empty() || filter_dids.contains(&did)) 291 291 + .filter(|(_, (did, _))| filter_dids.is_empty() || filter_dids.contains(did)) 292 292 { 293 293 - let Some(links) = data.links.get(&did).and_then(|m| { 293 293 + let Some(links) = data.links.get(did).and_then(|m| { 294 294 m.get(&RepoId { 295 295 collection: collection.to_string(), 296 296 rkey: rkey.clone(),

+1

constellation/src/storage/mod.rs

··· 142 142 fn get_all_record_counts(&self, _target: &str) 143 143 -> Result<HashMap<String, HashMap<String, u64>>>; 144 144 145 145 + #[allow(clippy::too_many_arguments)] 145 146 fn get_many_to_many( 146 147 &self, 147 148 target: &str,

+1 -1

constellation/src/storage/rocks_store.rs

··· 1060 1060 // if we have a full page, and we're inserting a *new* key less than 1061 1061 // the current max, then we can evict the current max 1062 1062 let mut should_evict = false; 1063 1063 - let entry = grouped_counts.entry(fwd_target.clone()).or_insert_with(|| { 1063 1063 + let entry = grouped_counts.entry(fwd_target).or_insert_with(|| { 1064 1064 // this is a *new* key, so kick the max if we're full 1065 1065 should_evict = page_is_full; 1066 1066 Default::default()