Searched refs:msg (Results 1 – 4 of 4) sorted by relevance
200 if let Ok(msg) = rr.marshal() { in send_rr()206 bytes_writer.write_u16::<BigEndian>(msg.len() as u16)?; in send_rr()210 bytes_writer.write(&msg)?; in send_rr()
302 move |msg: FrameData| -> Result<(), UnPackerError> { in handle_announce()303 if let Err(err) = sender_out.send(msg) { in handle_announce()430 let msg = packet.marshal()?; in handle_play() localVariable434 bytes_writer.write_u16::<BigEndian>(msg.len() as u16)?; in handle_play()435 bytes_writer.write(&msg)?; in handle_play()448 let msg = packet.marshal()?; in handle_play() localVariable449 bytes_writer.write(&msg)?; in handle_play()
192 if let Some(mut msg) = in run()196 self.process_messages(&mut msg, ×tamp).await?; in run()233 msg: &mut RtmpMessageData, in process_messages()236 match msg { in process_messages()
190 if let Some(mut msg) = MessageParser::new(chunk_info).parse()? { in read_parse_chunks()191 self.process_messages(&mut msg, &msg_stream_id, ×tamp) in read_parse_chunks()