pub fn process_buffered_events<Parser, StreamTransformer>( transformer: &mut StreamTransformer, events: Vec<Parser::Message>, ) -> VecDeque<Result<StreamTransformer::Output, StreamTransformer::Error>>where Parser: StreamParser<StreamTransformer::Input>, StreamTransformer: Transformer,