Function parse_message_stream 

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