accumulate_all

dfir_rs::compiled::pull

Function accumulate_all 

Source 
pub async fn accumulate_all<Key, ValAccum, ValIn>(
    accum: &mut impl Accumulator<ValAccum, ValIn>,
    hash_map: &mut HashMap<Key, ValAccum, impl BuildHasher>,
    st: impl Stream<Item = (Key, ValIn)>,
)
where
    Key: Eq + Hash,
Expand description

Use the accumulator accum to accumulate all entries in the stream st into the hash_map.