Lines Matching refs:buf
30 buf: BytesMut, field
130 frame.map_data(|mut buf| buf.copy_to_bytes(buf.remaining())) in new()
136 buf: BytesMut::with_capacity(buffer_size), in new()
152 if self.buf.remaining() < HEADER_SIZE { in decode_chunk()
156 let compression_encoding = match self.buf.get_u8() { in decode_chunk()
185 let len = self.buf.get_u32() as usize; in decode_chunk()
198 self.buf.reserve(len); in decode_chunk()
209 if self.buf.remaining() < len || self.buf.len() < len { in decode_chunk()
221 &mut self.buf, in decode_chunk()
238 DecodeBuf::new(&mut self.buf, len) in decode_chunk()
262 return Poll::Ready(if self.buf.has_remaining() { in poll_frame()
272 self.buf.put(frame.into_data().unwrap()); in poll_frame()