Lines Matching refs:reader
9 protocol_control_messages::reader::ProtocolControlMessageReader,
10 user_control_messages::reader::EventMessagesReader,
25 let mut reader = BytesReader::new(self.chunk_info.payload); in parse() localVariable
30 reader.read_u8()?; in parse()
32 let mut amf_reader = Amf0Reader::new(reader); in parse()
68 data: reader.extract_remaining_bytes(), in parse()
77 data: reader.extract_remaining_bytes(), in parse()
85 let data = EventMessagesReader::new(reader).parse_event()?; in parse()
89 let chunk_size = ProtocolControlMessageReader::new(reader).read_set_chunk_size()?; in parse()
94 ProtocolControlMessageReader::new(reader).read_abort_message()?; in parse()
99 ProtocolControlMessageReader::new(reader).read_acknowledgement()?; in parse()
104 ProtocolControlMessageReader::new(reader).read_window_acknowledgement_size()?; in parse()
109 ProtocolControlMessageReader::new(reader).read_set_peer_bandwidth()?; in parse()
115 raw_data: reader.extract_remaining_bytes(), in parse()