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