Lines Matching refs:chunks
94 pub(crate) async fn append(&self, chunks: Vec<ChunkPayloadData>) { in append()
95 if chunks.is_empty() { in append()
99 let total_user_data_len = chunks.iter().fold(0, |acc, c| acc + c.user_data.len()); in append()
102 self.append_large(chunks).await in append()
111 self.append_unlimited(chunks, total_user_data_len); in append()
116 async fn append_large(&self, chunks: Vec<ChunkPayloadData>) { in append_large()
120 for chunk in chunks.into_iter() { in append_large()
139 fn append_unlimited(&self, chunks: Vec<ChunkPayloadData>, total_user_data_len: usize) { in append_unlimited()
140 let chunks_len = chunks.len(); in append_unlimited()
141 let unordered = chunks in append_unlimited()
148 chunks.iter().all(|c| c.unordered), in append_unlimited()
151 unordered_queue.extend(chunks); in append_unlimited()
155 chunks.iter().all(|c| !c.unordered), in append_unlimited()
158 ordered_queue.extend(chunks); in append_unlimited()