39     fn zip_chunk_header(&mut self, chunk_info: &mut ChunkInfo) -> Result<PackResult, PackError> {  in zip_chunk_header()
40         chunk_info.basic_header.format = 0;  in zip_chunk_header()
44             .get_mut(&chunk_info.basic_header.chunk_stream_id)  in zip_chunk_header()
46             let cur_msg_header = &mut chunk_info.message_header;  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()
71             assert_eq!(chunk_info.message_header.timestamp_delta, 0);  in zip_chunk_header()
76             chunk_info.basic_header.chunk_stream_id,  in zip_chunk_header()
78                 basic_header: chunk_info.basic_header.clone(),  in zip_chunk_header()
79                 message_header: chunk_info.message_header.clone(),  in zip_chunk_header()
169     pub async fn write_chunk(&mut self, chunk_info: &mut ChunkInfo) -> Result<(), PackError> {  in write_chunk()
170         self.zip_chunk_header(chunk_info)?;  in write_chunk()
174             chunk_info.message_header.timestamp,  in write_chunk()
177         let mut whole_payload_size = chunk_info.payload.len();  in write_chunk()
180             chunk_info.basic_header.format,  in write_chunk()
181             chunk_info.basic_header.chunk_stream_id,  in write_chunk()
184         self.write_message_header(&chunk_info.basic_header, &mut chunk_info.message_header)?;  in write_chunk()
198             let payload_bytes = chunk_info.payload.split_to(cur_payload_size);  in write_chunk()
204                 self.write_basic_header(3, chunk_info.basic_header.chunk_stream_id)?;  in write_chunk()