Home
last modified time | relevance | path

Searched refs:amf_reader (Results 1 – 2 of 2) sorted by relevance

/xiu/protocol/rtmp/src/messages/
H A Dparser.rs32 let mut amf_reader = Amf0Reader::new(reader); in parse() localVariable
34 let command_name = amf_reader.read_with_type(amf0_markers::STRING)?; in parse()
35 let transaction_id = amf_reader.read_with_type(amf0_markers::NUMBER)?; in parse()
45 let command_obj_raw = amf_reader.read_with_type(amf0_markers::OBJECT); in parse()
48 Err(_) => amf_reader.read_with_type(amf0_markers::NULL)?, in parse()
51 let others = amf_reader.read_all()?; in parse()
/xiu/protocol/rtmp/src/amf0/
H A Damf0_reader.rs202 let mut amf_reader = Amf0Reader::new(bytes_reader); in test_amf_reader() localVariable
204 let command_name = amf_reader.read_with_type(amf0_markers::STRING).unwrap(); in test_amf_reader()
210 let transaction_id = amf_reader.read_with_type(amf0_markers::NUMBER).unwrap(); in test_amf_reader()
213 let command_obj_raw = amf_reader.read_with_type(amf0_markers::OBJECT).unwrap(); in test_amf_reader()
237 let _ = amf_reader.read_all(); in test_amf_reader()
329 let mut amf_reader = Amf0Reader::new(bytes_reader); in test_player_connect_reader() localVariable
331 let command_name = amf_reader.read_with_type(amf0_markers::STRING).unwrap(); in test_player_connect_reader()
338 let transaction_id = amf_reader.read_with_type(amf0_markers::NUMBER).unwrap(); in test_player_connect_reader()
341 let command_obj_raw = amf_reader.read_with_type(amf0_markers::OBJECT); in test_player_connect_reader()