risingwave_storage::table::batch_table::merge_vnode_stream

Function merge_stream

Source 
pub(super) fn merge_stream<R: Send, RowSt: Stream<Item = StorageResult<((), R)>> + Send, KeyedRowSt: Stream<Item = StorageResult<(Bytes, R)>> + Send>(
    stream: VnodeStreamType<RowSt, KeyedRowSt>,
) -> impl Stream<Item = StorageResult<R>> + Send
where
    KeyedRow<Bytes, R>: NodePeek + Send + Sync,