65     buf: BytesMut,  field
77             buf: Default::default(),  in default()
107             buf: BytesMut::with_capacity(match (direction, encoding) {  in new_client()
125             buf: BytesMut::with_capacity(match (direction, encoding) {  in new()
141         (self.buf.len() / 4) * 4  in max_decodable()
146         if self.buf.is_empty() || self.buf.len() < 4 {  in decode_chunk()
155             .decode(self.as_mut().project().buf.split_to(index))  in decode_chunk()
184                         .buf  in poll_decode()
196                         return if this.buf.has_remaining() {  in poll_decode()
292                 let buf = me.as_mut().project().decoded;  in poll_frame()  localVariable
294                 return match find_trailers(&buf[..])? {  in poll_frame()
297                         let msg_buf = buf.copy_to_bytes(len);  in poll_frame()
298                         match decode_trailers_frame(buf.split().freeze()) {  in poll_frame()
317                         _ => Some(Ok(Frame::data(buf.split_to(len).freeze()))),  in poll_frame()
390 fn decode_trailers_frame(mut buf: Bytes) -> Result<Option<HeaderMap>, Status> {  in decode_trailers_frame()
391     if buf.remaining() < GRPC_HEADER_SIZE {  in decode_trailers_frame()
395     buf.get_u8();  in decode_trailers_frame()
396     buf.get_u32();  in decode_trailers_frame()
399     let mut temp_buf = buf.clone();  in decode_trailers_frame()
404     for (i, b) in buf.iter().enumerate() {  in decode_trailers_frame()
406         if b == &b'\r' && buf.get(i + 1) == Some(&b'\n') {  in decode_trailers_frame()
463 fn find_trailers(buf: &[u8]) -> Result<FindTrailers, Status> {  in find_trailers()
465     let mut temp_buf = buf;  in find_trailers()
493         if len > buf.len() {  in find_trailers()
497         temp_buf = &buf[len..];  in find_trailers()
555         let buf = [  in find_trailers_non_buffered()  localVariable
559         let out = find_trailers(&buf[..]).unwrap();  in find_trailers_non_buffered()
568         let buf = [  in find_trailers_buffered()  localVariable
576         let out = find_trailers(&buf[..]).unwrap();  in find_trailers_buffered()
580         let trailers = decode_trailers_frame(Bytes::copy_from_slice(&buf[81..]))  in find_trailers_buffered()
589         let buf = vec![  in find_trailers_buffered_incomplete_message()  localVariable
618         let out = find_trailers(&buf[..]).unwrap();  in find_trailers_buffered_incomplete_message()
626         let buf = std::fs::read("tests/incomplete-buf-bug.bin").unwrap();  in find_trailers_buffered_incomplete_buf_bug()  localVariable
627         let out = find_trailers(&buf[..]).unwrap_err();  in find_trailers_buffered_incomplete_buf_bug()
634         let buf = b"\x80\0\0\0\x0fgrpc-status:0\r\ngrpc-message:\r\na:1\r\nb:2\r\n";  in decode_multiple_trailers()  localVariable
636         let trailers = decode_trailers_frame(Bytes::copy_from_slice(&buf[..]))  in decode_multiple_trailers()
651         let buf = b"\x80\0\0\0\x0fgrpc-status: 0\r\ngrpc-message: \r\n";  in decode_trailers_with_space_after_colon()  localVariable
653         let trailers = decode_trailers_frame(Bytes::copy_from_slice(&buf[..]))  in decode_trailers_with_space_after_colon()