Function collect_data_chunk

pub async fn collect_data_chunk<E, S, R>(
    stream: &mut S,
    schema: &Schema,
    chunk_size: Option<usize>,
) -> Result<Option<DataChunk>, E>
where
    S: Stream<Item = Result<R, E>> + Unpin,
    R: Row,