Function into_data_chunk_stream 

pub(crate) fn into_data_chunk_stream(
    stream: impl Stream<Item = ConnectorResult<SourceReaderEvent>> + Send + 'static,
) -> impl SourceChunkStream