Home
last modified time | relevance | path

Searched refs:ChunkInfo (Results 1 – 7 of 7) sorted by relevance

/xiu/protocol/rtmp/src/chunk/
H A Dmod.rs98 pub struct ChunkInfo { struct
104 impl fmt::Debug for ChunkInfo { argument
123 impl Default for ChunkInfo { implementation
129 impl ChunkInfo { implementation
H A Dunpacketizer.rs5 ChunkBasicHeader, ChunkInfo, ChunkMessageHeader, ExtendTimestampType,
21 ChunkInfo(ChunkInfo), enumerator
22 Chunks(Vec<ChunkInfo>),
80 pub current_chunk_info: ChunkInfo,
100 current_chunk_info: ChunkInfo::default(), in new()
141 let mut chunks: Vec<ChunkInfo> = Vec::new(); in read_chunks()
147 UnpackResult::ChunkInfo(chunk_info) => { in read_chunks()
625 return Ok(UnpackResult::ChunkInfo(chunk_info)); in read_message_payload()
637 use super::ChunkInfo;
663 let expected = ChunkInfo::new(2, 0, 0, 4, 1, 0, body); in test_set_chunk_size()
[all …]
H A Dpacketizer.rs3 define::CHUNK_SIZE, errors::PackError, ChunkBasicHeader, ChunkHeader, ChunkInfo,
39 fn zip_chunk_header(&mut self, chunk_info: &mut ChunkInfo) -> Result<PackResult, PackError> { in zip_chunk_header()
169 pub async fn write_chunk(&mut self, chunk_info: &mut ChunkInfo) -> Result<(), PackError> { in write_chunk()
/xiu/protocol/rtmp/src/messages/
H A Dparser.rs8 chunk::ChunkInfo,
17 chunk_info: ChunkInfo,
21 pub fn new(chunk_info: ChunkInfo) -> Self { in new()
176 if let UnpackResult::ChunkInfo(chunk_info) = rv { in test_message_parse()
/xiu/protocol/rtmp/src/session/
H A Dcommon.rs15 ChunkInfo,
111 let mut chunk_info = ChunkInfo::new( in send_audio()
129 let mut chunk_info = ChunkInfo::new( in send_video()
151 let mut chunk_info = ChunkInfo::new( in send_metadata()
/xiu/protocol/rtmp/src/netstream/
H A Dwriter.rs5 chunk::{define as chunk_define, packetizer::ChunkPacketizer, ChunkInfo},
29 let mut chunk_info = ChunkInfo::new( in write_chunk()
/xiu/protocol/rtmp/src/netconnection/
H A Dwriter.rs5 chunk::{define as chunk_define, packetizer::ChunkPacketizer, ChunkInfo},
79 let mut chunk_info = ChunkInfo::new( in write_chunk()