Home
last modified time | relevance | path

Searched refs:RtmpMessageData (Results 1 – 5 of 5) sorted by relevance

/xiu/protocol/rtmp/src/user_control_messages/
H A Dreader.rs19 ) -> Result<message_define::RtmpMessageData, errors::EventMessagesError> { in parse_event() argument
43 ) -> Result<message_define::RtmpMessageData, errors::EventMessagesError> { in read_set_buffer_length() argument
47 Ok(message_define::RtmpMessageData::SetBufferLength { in read_set_buffer_length()
55 ) -> Result<message_define::RtmpMessageData, errors::EventMessagesError> { in read_stream_begin() argument
58 Ok(message_define::RtmpMessageData::StreamBegin { in read_stream_begin()
65 ) -> Result<message_define::RtmpMessageData, errors::EventMessagesError> { in read_stream_is_recorded() argument
68 Ok(message_define::RtmpMessageData::StreamIsRecorded { in read_stream_is_recorded()
/xiu/protocol/rtmp/src/messages/
H A Dparser.rs3 define::{msg_type_id, RtmpMessageData},
24 pub fn parse(self) -> Result<Option<RtmpMessageData>, MessageError> { in parse() argument
53 return Ok(Some(RtmpMessageData::Amf0Command { in parse()
67 return Ok(Some(RtmpMessageData::AudioData { in parse()
76 return Ok(Some(RtmpMessageData::VideoData { in parse()
90 return Ok(Some(RtmpMessageData::SetChunkSize { chunk_size })); in parse()
95 return Ok(Some(RtmpMessageData::AbortMessage { chunk_stream_id })); in parse()
100 return Ok(Some(RtmpMessageData::Acknowledgement { sequence_number })); in parse()
105 return Ok(Some(RtmpMessageData::WindowAcknowledgementSize { size })); in parse()
110 return Ok(Some(RtmpMessageData::SetPeerBandwidth { properties })); in parse()
[all …]
H A Ddefine.rs17 pub enum RtmpMessageData { enum
/xiu/protocol/rtmp/src/session/
H A Dclient_session.rs18 messages::{define::RtmpMessageData, parser::MessageParser},
233 msg: &mut RtmpMessageData, in process_messages() argument
237 RtmpMessageData::Amf0Command { in process_messages()
247 RtmpMessageData::SetPeerBandwidth { .. } => { in process_messages()
251 RtmpMessageData::WindowAcknowledgementSize { .. } => { in process_messages()
254 RtmpMessageData::SetChunkSize { chunk_size } => { in process_messages()
258 RtmpMessageData::StreamBegin { stream_id } => { in process_messages()
262 RtmpMessageData::StreamIsRecorded { stream_id } => { in process_messages()
266 RtmpMessageData::AudioData { data } => { in process_messages()
269 RtmpMessageData::VideoData { data } => { in process_messages()
[all …]
H A Dserver_session.rs18 messages::{define::RtmpMessageData, parser::MessageParser},
243 rtmp_msg: &mut RtmpMessageData, in process_messages() argument
248 RtmpMessageData::Amf0Command { in process_messages()
263 RtmpMessageData::SetChunkSize { chunk_size } => { in process_messages()
266 RtmpMessageData::AudioData { data } => { in process_messages()
269 RtmpMessageData::VideoData { data } => { in process_messages()
272 RtmpMessageData::AmfData { raw_data } => { in process_messages()