Searched refs:process_messages (Results 1 – 2 of 2) sorted by relevance
196 self.process_messages(&mut msg, ×tamp).await?; in run()231 pub async fn process_messages( in process_messages() method
191 self.process_messages(&mut msg, &msg_stream_id, ×tamp) in read_parse_chunks()241 pub async fn process_messages( in process_messages() method