| /xiu/protocol/rtmp/src/amf0/ |
| H A D | amf0_reader.rs | 23 Amf0ValueType::END => { in read_all()
35 return Ok(Amf0ValueType::END); in read_any()
40 return Ok(Amf0ValueType::END); in read_any()
70 let value = Amf0ValueType::Number(number); in read_number()
78 1 => Ok(Amf0ValueType::Boolean(true)), in read_bool()
94 Ok(Amf0ValueType::UTF8String(raw_string)) in read_string()
98 Ok(Amf0ValueType::Null) in read_null()
126 Ok(Amf0ValueType::Object(properties)) in read_object()
146 Ok(Amf0ValueType::Object(properties)) in read_ecma_array()
155 Ok(Amf0ValueType::LongUTF8String(val)) in read_long_string()
[all …]
|
| H A D | amf0_writer.rs | 2 super::{amf0_markers, errors::Amf0WriteErrorValue, Amf0ValueType, Amf0WriteError},
20 pub fn write_anys(&mut self, values: &Vec<Amf0ValueType>) -> Result<(), Amf0WriteError> { in write_anys()
27 pub fn write_any(&mut self, value: &Amf0ValueType) -> Result<(), Amf0WriteError> { in write_any()
29 Amf0ValueType::Boolean(ref val) => self.write_bool(val), in write_any()
30 Amf0ValueType::Null => self.write_null(), in write_any()
31 Amf0ValueType::Number(ref val) => self.write_number(val), in write_any()
32 Amf0ValueType::UTF8String(ref val) => self.write_string(val), in write_any()
33 Amf0ValueType::Object(ref val) => self.write_object(val), in write_any()
34 Amf0ValueType::EcmaArray(ref val) => self.write_eacm_array(val), in write_any()
78 properties: &IndexMap<String, Amf0ValueType>, in write_object() argument
[all …]
|
| H A D | define.rs | 4 pub enum Amf0ValueType { enum
8 Object(IndexMap<String, Amf0ValueType>),
10 EcmaArray(IndexMap<String, Amf0ValueType>),
|
| H A D | mod.rs | 10 pub use self::define::Amf0ValueType;
|
| /xiu/protocol/rtmp/src/netconnection/ |
| H A D | writer.rs | 4 amf0::{amf0_writer::Amf0Writer, define::Amf0ValueType},
96 properties: IndexMap<String, Amf0ValueType>, in write_connect_with_value() argument
126 Amf0ValueType::UTF8String(flash_ver), in write_connect()
149 Amf0ValueType::Number(capabilities), in write_connect()
156 Amf0ValueType::Number(audio_codecs), in write_connect()
163 Amf0ValueType::Number(video_codecs), in write_connect()
170 Amf0ValueType::Number(video_function), in write_connect()
177 Amf0ValueType::Number(object_encoding), in write_connect()
206 Amf0ValueType::Number(*capabilities), in write_connect_response()
219 Amf0ValueType::UTF8String(code.to_owned()), in write_connect_response()
[all …]
|
| /xiu/protocol/rtmp/src/session/ |
| H A D | server_session.rs | 11 amf0::Amf0ValueType,
284 command_name: &Amf0ValueType, in on_amf0_command_message() argument
285 transaction_id: &Amf0ValueType, in on_amf0_command_message() argument
286 command_object: &Amf0ValueType, in on_amf0_command_message() argument
287 others: &mut Vec<Amf0ValueType>, in on_amf0_command_message() argument
291 Amf0ValueType::UTF8String(str) => str, in on_amf0_command_message()
302 Amf0ValueType::Object(obj) => obj, in on_amf0_command_message()
538 other_values: &mut Vec<Amf0ValueType>, in on_play() argument
667 other_values: &mut Vec<Amf0ValueType>, in on_publish() argument
678 Amf0ValueType::UTF8String(val) => val, in on_publish()
[all …]
|
| H A D | client_session.rs | 11 amf0::Amf0ValueType,
283 command_name: &Amf0ValueType, in on_amf0_command_message() argument
284 transaction_id: &Amf0ValueType, in on_amf0_command_message() argument
285 command_object: &Amf0ValueType, in on_amf0_command_message() argument
286 others: &mut Vec<Amf0ValueType>, in on_amf0_command_message() argument
291 Amf0ValueType::UTF8String(str) => str, in on_amf0_command_message()
296 Amf0ValueType::Number(number) => *number as u8, in on_amf0_command_message()
300 let empty_cmd_obj: IndexMap<String, Amf0ValueType> = IndexMap::new(); in on_amf0_command_message()
302 Amf0ValueType::Object(obj) => obj, in on_amf0_command_message()
522 obj: &IndexMap<String, Amf0ValueType>, in on_status() argument
[all …]
|
| /xiu/protocol/rtmp/src/messages/ |
| H A D | define.rs | 1 use {crate::amf0::define::Amf0ValueType, bytes::BytesMut};
19 command_name: Amf0ValueType,
20 transaction_id: Amf0ValueType,
21 command_object: Amf0ValueType,
22 others: Vec<Amf0ValueType>,
|
| /xiu/protocol/rtmp/src/cache/ |
| H A D | metadata.rs | 3 crate::amf0::{amf0_reader::Amf0Reader, amf0_writer::Amf0Writer, Amf0ValueType},
47 let mut values: Vec<Amf0ValueType> = Vec::new(); in is_metadata()
64 if let Amf0ValueType::UTF8String(str) = values.remove(0) { in is_metadata()
|
| /xiu/protocol/rtmp/src/netstream/ |
| H A D | writer.rs | 4 amf0::{amf0_writer::Amf0Writer, define::Amf0ValueType},
211 Amf0ValueType::UTF8String(level.to_owned()), in write_on_status()
215 Amf0ValueType::UTF8String(code.to_owned()), in write_on_status()
219 Amf0ValueType::UTF8String(description.to_owned()), in write_on_status()
|
| /xiu/protocol/rtmp/src/remuxer/ |
| H A D | rtsp2rtmp.rs | 15 amf0::{amf0_writer::Amf0Writer, Amf0ValueType},
348 properties.insert(String::from("width"), Amf0ValueType::Number(width as f64)); in gen_rtmp_meta_data()
349 properties.insert(String::from("height"), Amf0ValueType::Number(height as f64)); in gen_rtmp_meta_data()
350 properties.insert(String::from("videocodecid"), Amf0ValueType::Number(7.)); in gen_rtmp_meta_data()
351 properties.insert(String::from("audiocodecid"), Amf0ValueType::Number(10.)); in gen_rtmp_meta_data()
|