Searched refs:frame (Results 1 – 5 of 5) sorted by relevance
129 body.map_frame(|frame| { in new()130 frame.map_data(|mut buf| buf.copy_to_bytes(buf.remaining())) in new()249 let frame = match ready!(Pin::new(&mut self.body).poll_frame(cx)) { in poll_frame() localVariable250 Some(Ok(frame)) => frame, in poll_frame()271 Poll::Ready(if frame.is_data() { in poll_frame()272 self.buf.put(frame.into_data().unwrap()); in poll_frame()274 } else if frame.is_trailers() { in poll_frame()276 trailers.extend(frame.into_trailers().unwrap()); in poll_frame()278 self.trailers = Some(frame.into_trailers().unwrap()); in poll_frame()283 panic!("unexpected frame: {:?}", frame); in poll_frame()
239 while let Some(r) = body.frame().await { in encode()261 let frame = body in encode_max_message_size_exceeded() localVariable262 .frame() in encode_max_message_size_exceeded()267 frame in encode_max_message_size_exceeded()298 let frame = body in encode_too_big() localVariable299 .frame() in encode_too_big()304 frame in encode_too_big()
183 Some(Ok(frame)) if frame.is_data() => this in poll_decode()185 .put(frame.into_data().unwrap_or_else(|_| unreachable!())), in poll_decode()186 Some(Ok(frame)) if frame.is_trailers() => { in poll_decode()223 Some(Ok(frame)) if frame.is_data() => { in poll_encode()224 let mut data = frame.into_data().unwrap_or_else(|_| unreachable!()); in poll_encode()233 Some(Ok(frame)) if frame.is_trailers() => { in poll_encode()451 let mut frame = BytesMut::with_capacity(len + FRAME_HEADER_SIZE); in make_trailers_frame() localVariable452 frame.put_u8(GRPC_WEB_TRAILERS_BIT); in make_trailers_frame()453 frame.put_u32(len as u32); in make_trailers_frame()454 frame.put_slice(&trailers); in make_trailers_frame()[all …]
77 fn frame_data_length(frame: &http_body::Frame<Bytes>) -> usize { in frame_data_length()78 if let Some(data) = frame.data_ref() { in frame_data_length()109 let frame = ready!(self.project().rx.poll_recv(cx)); in poll_frame() localVariable110 Poll::Ready(frame.map(Ok)) in poll_frame()123 while let Some(chunk) = body.frame().await { in measure_request_body_size_layer()
472 * **transport:** add max http2 frame size to server. ([#529](https://github.com/hyperium/tonic/issu…