Searched refs:chunk_info (Results 1 – 8 of 8) sorted by relevance
40 chunk_info.basic_header.format = 0; in zip_chunk_header()52 chunk_info.basic_header.chunk_stream_id, in zip_chunk_header()57 chunk_info.basic_header.format = 1; in zip_chunk_header()64 chunk_info.basic_header.format = 2; in zip_chunk_header()66 chunk_info.basic_header.format = 3; in zip_chunk_header()76 chunk_info.basic_header.chunk_stream_id, in zip_chunk_header()170 self.zip_chunk_header(chunk_info)?; in write_chunk()174 chunk_info.message_header.timestamp, in write_chunk()180 chunk_info.basic_header.format, in write_chunk()181 chunk_info.basic_header.chunk_stream_id, in write_chunk()[all …]
147 UnpackResult::ChunkInfo(chunk_info) => { in read_chunks()148 let msg_type_id = chunk_info.message_header.msg_type_id; in read_chunks()149 chunks.push(chunk_info); in read_chunks()618 let chunk_info = self.current_chunk_info.clone(); in read_message_payload() localVariable625 return Ok(UnpackResult::ChunkInfo(chunk_info)); in read_message_payload()
17 chunk_info: ChunkInfo, field21 pub fn new(chunk_info: ChunkInfo) -> Self { in new()22 Self { chunk_info } in new()25 let mut reader = BytesReader::new(self.chunk_info.payload); in parse()27 match self.chunk_info.message_header.msg_type_id { in parse()64 self.chunk_info.message_header.msg_length in parse()74 self.chunk_info.message_header.msg_length in parse()83 self.chunk_info.message_header.msg_length in parse()127 self.chunk_info.message_header.msg_type_id in parse()176 if let UnpackResult::ChunkInfo(chunk_info) = rv { in test_message_parse()[all …]
111 let mut chunk_info = ChunkInfo::new( in send_audio() localVariable122 packetizer.write_chunk(&mut chunk_info).await?; in send_audio()129 let mut chunk_info = ChunkInfo::new( in send_video() localVariable140 packetizer.write_chunk(&mut chunk_info).await?; in send_video()151 let mut chunk_info = ChunkInfo::new( in send_metadata() localVariable162 packetizer.write_chunk(&mut chunk_info).await?; in send_metadata()
186 for chunk_info in chunks { in read_parse_chunks()187 let timestamp = chunk_info.message_header.timestamp; in read_parse_chunks()188 let msg_stream_id = chunk_info.message_header.msg_streamd_id; in read_parse_chunks()190 if let Some(mut msg) = MessageParser::new(chunk_info).parse()? { in read_parse_chunks()
191 for chunk_info in chunks.iter() { in run()193 MessageParser::new(chunk_info.clone()).parse()? in run()195 let timestamp = chunk_info.message_header.timestamp; in run()
29 let mut chunk_info = ChunkInfo::new( in write_chunk() localVariable39 self.packetizer.write_chunk(&mut chunk_info).await?; in write_chunk()
79 let mut chunk_info = ChunkInfo::new( in write_chunk() localVariable89 self.packetizer.write_chunk(&mut chunk_info).await?; in write_chunk()