risingwave_storage::table::merge_sort

Function merge_sort

source 
pub fn merge_sort<E, KO, R>(
    streams: impl IntoIterator<Item = R>,
) -> impl Stream<Item = Result<KO, E>>
where
    KO: NodePeek + Send + Sync,
    E: Error,
    R: Stream<Item = Result<KO, E>> + Unpin,