risingwave_stream::executor::backfill::utils

Function iter_chunks

Source 
pub(crate) fn iter_chunks<'a, S, E, R>(
    iter: S,
    builder: &'a mut DataChunkBuilder,
) -> impl Stream<Item = Result<StreamChunk, StreamExecutorError>> + 'a
where
    StreamExecutorError: From<E>,
    R: Row,
    S: Stream<Item = Result<R, E>> + Unpin + 'a,