Searched refs:chunk (Results 1 – 4 of 4) sorted by relevance
59 Some(Ok(chunk)) => { in poll_frame()60 println!("response body chunk size = {}", frame_data_length(&chunk)); in poll_frame()61 counter.fetch_add(frame_data_length(&chunk), SeqCst); in poll_frame()62 Poll::Ready(Some(Ok(chunk))) in poll_frame()123 while let Some(chunk) = body.frame().await { in measure_request_body_size_layer()124 let chunk = chunk.unwrap(); in measure_request_body_size_layer() localVariable125 println!("request body chunk size = {}", frame_data_length(&chunk)); in measure_request_body_size_layer()126 bytes_sent_counter.fetch_add(frame_data_length(&chunk), SeqCst); in measure_request_body_size_layer()127 tx.send(chunk).await.unwrap(); in measure_request_body_size_layer()
30 fn chunk(&self) -> &[u8] { in chunk() method31 let ret = self.buf.chunk(); in chunk()120 assert_eq!(buf.chunk().len(), 20); in decode_buf()128 assert_eq!(buf.chunk().len(), 5); in decode_buf()
339 let out = Vec::from(buf.chunk()); in decode()
107 let out = Vec::from(buf.chunk()); in decode()