Function into_chunk_event_stream 

pub(crate) fn into_chunk_event_stream(
    data_stream: impl Stream<Item = ConnectorResult<SourceMessageEvent>> + Send + 'static,
    parser_config: ParserConfig,
    source_ctx: SourceContextRef,
) -> Pin<Box<dyn Stream<Item = Result<SourceReaderEvent, ConnectorError>> + Send>>