common_procedure::store::util

Function multiple_value_stream

Source
pub fn multiple_value_stream(
    upstream: Pin<Box<dyn Stream<Item = Result<(String, Vec<u8>)>> + Send>>,
) -> impl Stream<Item = Result<(KeySet, Vec<u8>)>>
Expand description

Merges multiple values that have the same prefix of the key from upstream into a single value.