Searched refs:trailers (Results 1 – 10 of 10) sorted by relevance
| /tonic/tonic-web/src/ |
| H A D | call.rs | 70 trailers: Option<HeaderMap>, field
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()
280 me.as_mut().project().trailers.replace(trailers); in poll_frame()
300 me.as_mut().project().trailers.replace(trailers); in poll_frame()
309 Poll::Ready(Some(Ok(Frame::trailers(trailers)))) in poll_frame()
420 for trailer in trailers { in decode_trailers_frame()
447 let trailers = encode_trailers(trailers); in make_trailers_frame() localVariable
[all …]
|
| /tonic/tonic/src/codec/ |
| H A D | decode.rs | 31 trailers: Option<HeaderMap>, field
137 trailers: None, in new()
275 if let Some(trailers) = &mut self.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()
292 self.trailers.take(); in response()
352 pub async fn trailers(&mut self) -> Result<Option<MetadataMap>, Status> { in trailers() method
355 if let Some(trailers) = self.inner.trailers.take() { in trailers()
356 return Ok(Some(MetadataMap::from_headers(trailers))); in trailers()
364 if let Some(trailers) = self.inner.trailers.take() { in trailers()
[all …]
|
| H A D | encode.rs | 283 fn trailers(&mut self) -> Option<Result<HeaderMap, Status>> { in trailers() method
326 Some(Ok(Frame::trailers(status.to_header_map()?))).into() in poll_frame()
331 .trailers() in poll_frame()
332 .map(|t| t.map(Frame::trailers)) in poll_frame()
|
| /tonic/tests/web/tests/ |
| H A D | grpc_web.rs | 35 let (message, trailers) = decode_body(res.into_body(), content_type).await; in binary_request()
42 assert_eq!(&trailers[..], b"grpc-status:0\r\n"); in binary_request()
58 let (message, trailers) = decode_body(res.into_body(), content_type).await; in text_request()
65 assert_eq!(&trailers[..], b"grpc-status:0\r\n"); in text_request()
|
| /tonic/interop/src/ |
| H A D | client.rs | 393 let trailers = stream.trailers().await.unwrap().unwrap(); in custom_metadata() localVariable
397 trailers.get_bin(key2) == Some(&value2), in custom_metadata()
398 format!("result={:?}", trailers.get_bin(key1)) in custom_metadata()
|
| /tonic/tonic/src/client/ |
| H A D | grpc.rs | 255 if let Some(trailers) = body.trailers().await? { in client_streaming()
256 parts.merge(trailers); in client_streaming()
|
| /tonic/tonic/src/server/ |
| H A D | grpc.rs | 390 if let Some(trailers) = stream.trailers().await? { in map_request_unary()
391 req.metadata_mut().merge(trailers); in map_request_unary()
|
| /tonic/tonic/benches/ |
| H A D | decode.rs | 36 assert!(stream.trailers().await.unwrap().is_none());
|
| /tonic/tonic/src/ |
| H A D | status.rs | 735 trailers: Option<&HeaderMap>, in infer_grpc_status()
738 if let Some(trailers) = trailers { in infer_grpc_status()
739 if let Some(status) = Status::from_header_map(trailers) { in infer_grpc_status()
|
| /tonic/ |
| H A D | CHANGELOG.md | 35 * **web:** fix panic in trailer parsing on multiple trailers (#1880)
|