Lines Matching refs:trailers
70 trailers: Option<HeaderMap>, field
82 trailers: Default::default(), in default()
118 trailers: None, in new_client()
133 trailers: None, in new()
198 } else if let Some(trailers) = this.trailers.take() { in poll_decode()
199 Poll::Ready(Some(Ok(Frame::trailers(trailers)))) in poll_decode()
234 let trailers = frame.into_trailers().unwrap_or_else(|_| unreachable!()); in poll_encode() localVariable
235 let mut res = make_trailers_frame(trailers); in poll_encode()
274 let trailers = incoming_buf.into_trailers().unwrap(); in poll_frame() localVariable
275 match me.as_mut().project().trailers { in poll_frame()
277 current_trailers.extend(trailers); in poll_frame()
280 me.as_mut().project().trailers.replace(trailers); in poll_frame()
299 Ok(Some(trailers)) => { in poll_frame()
300 me.as_mut().project().trailers.replace(trailers); in poll_frame()
308 } else if let Some(trailers) = me.as_mut().project().trailers.take() { in poll_frame()
309 Poll::Ready(Some(Ok(Frame::trailers(trailers)))) in poll_frame()
380 fn encode_trailers(trailers: HeaderMap) -> Vec<u8> { in encode_trailers()
381 trailers.iter().fold(Vec::new(), |mut acc, (key, value)| { in encode_trailers()
401 let mut trailers = Vec::new(); in decode_trailers_frame() localVariable
411 trailers.push(trailer); in decode_trailers_frame()
420 for trailer in trailers { in decode_trailers_frame()
446 fn make_trailers_frame(trailers: HeaderMap) -> Bytes { in make_trailers_frame()
447 let trailers = encode_trailers(trailers); in make_trailers_frame() localVariable
448 let len = trailers.len(); in make_trailers_frame()
454 frame.put_slice(&trailers); in make_trailers_frame()
544 let trailers = make_trailers_frame(headers.clone()); in decode_trailers() localVariable
546 let map = decode_trailers_frame(trailers).unwrap().unwrap(); in decode_trailers()
580 let trailers = decode_trailers_frame(Bytes::copy_from_slice(&buf[81..])) in find_trailers_buffered() localVariable
583 let status = trailers.get(Status::GRPC_STATUS).unwrap(); in find_trailers_buffered()
636 let trailers = decode_trailers_frame(Bytes::copy_from_slice(&buf[..])) in decode_multiple_trailers() localVariable
646 assert_eq!(trailers, expected); in decode_multiple_trailers()
653 let trailers = decode_trailers_frame(Bytes::copy_from_slice(&buf[..])) in decode_trailers_with_space_after_colon() localVariable
661 assert_eq!(trailers, expected); in decode_trailers_with_space_after_colon()