Function into_chunk_stream_inner

fn into_chunk_stream_inner<P: ByteStreamSourceParser>(
    parser: P,
    data_stream: BoxSourceStream,
) -> impl Stream<Item = Result<StreamChunk, ConnectorError>>