Searched refs:read_bytes (Results 1 – 16 of 16) sorted by relevance
54 reader.read_bytes(4 * rtp_packet.header_extension_length as usize)?; in unmarshal()61 .put(reader.read_bytes(reader.len() - padding_length)?); in unmarshal()62 rtp_packet.padding.put(reader.read_bytes(padding_length)?); in unmarshal()
98 let fu_payload = nalu_reader.read_bytes(fu_payload_len)?; in pack_fu()262 payload_reader.read_bytes(2)?; in unpack_ap()267 payload_reader.read_bytes(2)?; in unpack_ap()272 let nalu = payload_reader.read_bytes(nalu_len)?; in unpack_ap()328 payload_reader.read_bytes(2)?; in unpack_fu()
73 let fu_payload = nalu_reader.read_bytes(fu_payload_len)?; in pack_fu_a()360 let nalu = payload_reader.read_bytes(length)?; in unpack_stap()454 let nalu = payload_reader.read_bytes(nalu_size - ts_bytes - 1)?; in unpack_mtap()
146 let au_data = reader_payload.read_bytes(*item)?; in unpack()
40 rtcp_app.name = reader.read_bytes(4)?; in unmarshal()41 rtcp_app.app_data = reader.read_bytes(rtcp_app.header.length as usize * 4)?; in unmarshal()
47 rtcp_bye.reason = reader.read_bytes(rtcp_bye.length as usize)?; in unmarshal()
99 self.s1_bytes = self.reader.read_bytes(define::RTMP_HANDSHAKE_SIZE)?; in read_s1()103 let _ = self.reader.read_bytes(define::RTMP_HANDSHAKE_SIZE)?; in read_s2()
147 let c1_bytes = self.reader.read_bytes(define::RTMP_HANDSHAKE_SIZE)?; in read_c1()157 self.reader.read_bytes(define::RTMP_HANDSHAKE_SIZE)?; in read_c2()191 let c1_bytes = self.reader.read_bytes(define::RTMP_HANDSHAKE_SIZE)?; in read_c1()209 self.reader.read_bytes(define::RTMP_HANDSHAKE_SIZE)?; in read_c2()
104 let left_part = new_reader.read_bytes(digest_offset)?; in cook_raw_message()105 let digest_data = new_reader.read_bytes(define::RTMP_DIGEST_LENGTH)?; in cook_raw_message()
32 pub fn read_bytes(&mut self, bytes_num: usize) -> Result<BytesMut, BytesReadError> { in read_bytes() method56 let tmp_bytes = self.read_bytes(bytes_num)?; in read_bytes_cursor()181 pub async fn read_bytes(&mut self, bytes_num: usize) -> Result<BytesMut, BytesReadError> { in read_bytes() function183 self.bytes_reader.read_bytes(bytes_num) in read_bytes()
225 self.bytes_reader.read_bytes(9)?; in read_flv_header()247 let body = self.bytes_reader.read_bytes(data_size as usize)?; in read_flv_tag()
173 data: bytes_reader.read_bytes(sps_data_size as usize)?, in decoder_configuration_record_load()213 data: bytes_reader.read_bytes(pps_data_size as usize)?, in decoder_configuration_record_load()257 let data = bytes_reader.read_bytes(size as usize)?; in h264_mp4toannexb()
86 let bytes = self.reader.read_bytes(l as usize)?; in read_raw_string()152 let buff = self.reader.read_bytes(l as usize)?; in read_long_string()
196 let data = payload_reader.read_bytes(payload_length)?; in write_pes()
605 let payload_data = self.reader.read_bytes(need_read_length)?; in read_message_payload()
158 let mut cur_reader = BytesReader::new(self.reader.read_bytes(length)?); in on_rtp_over_rtsp_message()