pub fn source_reader_event_to_chunk_stream(
stream: BoxSourceReaderEventStream,
) -> impl Stream<Item = Result<StreamChunk, ConnectorError>>pub fn source_reader_event_to_chunk_stream(
stream: BoxSourceReaderEventStream,
) -> impl Stream<Item = Result<StreamChunk, ConnectorError>>