risingwave_storage::table::batch_table

Function build_vnode_stream

source 
async fn build_vnode_stream<R: Send, RowSt: Stream<Item = StorageResult<((), R)>> + Send, KeyedRowSt: Stream<Item = StorageResult<(Bytes, R)>> + Send, RowStFut: Future<Output = StorageResult<RowSt>>, KeyedRowStFut: Future<Output = StorageResult<KeyedRowSt>>>(
    row_stream_fn: impl Fn(VirtualNode) -> RowStFut,
    keyed_row_stream_fn: impl Fn(VirtualNode) -> KeyedRowStFut,
    vnodes: &[VirtualNode],
    ordered: bool,
) -> StorageResult<impl Stream<Item = StorageResult<R>> + Send>
where
    KeyedRow<Bytes, R>: NodePeek + Send + Sync,