Function parse_message_stream

fn parse_message_stream<P: ByteStreamSourceParser>(
    parser: P,
    msg_stream: BoxSourceMessageStream,
    source_ctrl_opts: SourceCtrlOpts,
) -> impl Stream<Item = Result<StreamChunk, ConnectorError>>