| /tonic/tonic/src/metadata/ |
| H A D | mod.rs | 5 mod map; module
13 pub use self::map::Entry;
14 pub use self::map::GetAll;
15 pub use self::map::Iter;
16 pub use self::map::IterMut;
19 pub use self::map::KeyRef;
20 pub use self::map::Keys;
25 pub use self::map::ValueIter;
26 pub use self::map::ValueRef;
28 pub use self::map::Values;
[all …]
|
| H A D | map.rs | 2052 map.headers in insert()
2074 map.headers in insert()
2098 map.headers in insert()
2156 map.headers in get()
2164 map.headers in get_mut()
2187 map.headers in remove()
2199 map.headers in get()
2207 map.headers in get_mut()
2230 map.headers in remove()
2245 map.headers in get()
[all …]
|
| H A D | value.rs | 256 VE::from_bytes(src).map(|value| MetadataValue { in try_from()
311 VE::from_shared(src).map(|value| MetadataValue { in try_from()
549 use crate::metadata::map::MetadataMap;
553 let mut map = MetadataMap::new(); in it_can_insert_metadata_key_as_metadata_value() localVariable
554 map.insert( in it_can_insert_metadata_key_as_metadata_value()
562 map.get("accept").unwrap(), in it_can_insert_metadata_key_as_metadata_value()
574 .map(|value| MetadataValue { in from_str()
|
| /tonic/tests/compression/ |
| H A D | Cargo.toml | 21 tower-http = {version = "0.6", features = ["map-response-body", "map-request-body"]}
|
| /tonic/tonic-web/src/ |
| H A D | client.rs | 73 let req = req.map(GrpcWebCall::client_request); in call()
98 Poll::Ready(res.map(|r| r.map(GrpcWebCall::client_response))) in poll()
|
| H A D | call.rs | 156 .map(|decoded| Some(Bytes::from(decoded))) in decode_chunk()
398 let mut map = HeaderMap::new(); in decode_trailers_frame() localVariable
440 map.insert(header_key, header_value); in decode_trailers_frame()
443 Ok(Some(map)) in decode_trailers_frame()
546 let map = decode_trailers_frame(trailers).unwrap().unwrap(); in decode_trailers() localVariable
548 assert_eq!(headers, map); in decode_trailers()
|
| /tonic/tonic/src/codec/ |
| H A D | compression.rs | 109 map: &http::HeaderMap, in from_accept_encoding_header()
116 let header_value = map.get(ACCEPT_ENCODING_HEADER)?; in from_accept_encoding_header()
132 map: &http::HeaderMap, in from_encoding_header()
135 let Some(header_value) = map.get(ENCODING_HEADER) else { in from_encoding_header()
171 .map(MetadataValue::unchecked_from_header_value) in from_encoding_header()
206 s.split(',').map(|s| s.trim()) in split_by_comma()
|
| /tonic/tonic/src/client/ |
| H A D | grpc.rs | 221 let request = request.map(|m| tokio_stream::once(m)); in unary()
277 let request = request.map(|m| tokio_stream::once(m)); in server_streaming()
298 .map(|s| { in streaming()
301 s.map(Ok), in streaming()
306 .map(Body::new); in streaming()
353 let response = response.map(|body| { in create_response()
|
| /tonic/tonic-reflection/src/server/ |
| H A D | v1alpha.rs | 44 MessageRequest::FileByFilename(s) => state.file_by_filename(&s).map(|fd| { in server_reflection_info()
50 state.symbol_by_name(&s).map(|fd| { in server_reflection_info()
71 .map(|s| ServiceResponse { name: s.clone() }) in server_reflection_info()
|
| H A D | v1.rs | 44 MessageRequest::FileByFilename(s) => state.file_by_filename(&s).map(|fd| { in server_reflection_info()
50 state.symbol_by_name(&s).map(|fd| { in server_reflection_info()
71 .map(|s| ServiceResponse { name: s.clone() }) in server_reflection_info()
|
| /tonic/tonic/src/service/ |
| H A D | router.rs | 91 svc.map_request(|req: Request<axum::body::Body>| req.map(Body::new)), in add_service()
158 RoutesFuture(self.router.call(req.map(axum::body::Body::new))) in call()
175 Ok(res) => Ok(res.map(Body::new)).into(), in poll()
|
| /tonic/tonic/src/transport/server/ |
| H A D | unix.rs | 25 peer_addr: self.peer_addr().ok().map(Arc::new), in connect_info()
|
| /tonic/tonic/src/server/ |
| H A D | grpc.rs | 249 .map(|r| r.map(|m| tokio_stream::once(Ok(m)))); in unary()
323 .map(|r| r.map(|m| tokio_stream::once(Ok(m)))); in client_streaming()
407 let request = request.map(|body| { in map_request_streaming()
|
| /tonic/interop/src/ |
| H A D | server.rs | 204 .map(|v| HeaderMap::from_iter(std::iter::once((trailer_name, v)))); in call()
215 .map(|b| b.with_trailers(async move { echo_trailer.map(Ok) })) in call()
216 .map(Body::new)) in call()
|
| H A D | client.rs | 60 let payload_len = body.payload.as_ref().map(|p| p.body.len()).unwrap_or(0); in large_unary()
85 let requests = REQUEST_LENGTHS.iter().map(|len| StreamingInputCallRequest { in client_streaming()
115 .map(|len| ResponseParameters::with_size(*len)) in server_streaming()
169 if let Ok(mut response) = result.map(Response::into_inner) { in ping_pong()
219 if let Ok(response) = result.map(Response::into_inner) { in empty_stream()
|
| /tonic/examples/src/load_balance/ |
| H A D | client.rs | 12 .map(|a| Channel::from_static(a)); in main()
|
| /tonic/codegen/src/ |
| H A D | main.rs | 81 let iface_files = iface_files.iter().map(|&path| root_dir.join(path)); in codegen()
82 let include_dirs = include_dirs.iter().map(|&path| root_dir.join(path)); in codegen()
|
| /tonic/tonic/src/transport/channel/service/ |
| H A D | connection.rs | 66 .option_layer(endpoint.concurrency_limit.map(ConcurrencyLimitLayer::new)) in new()
67 .option_layer(endpoint.rate_limit.map(|(l, d)| RateLimitLayer::new(l, d))) in new()
154 Box::pin(async move { fut.await.map_err(Into::into).map(|res| res.map(Body::new)) }) in call()
|
| /tonic/examples/src/routeguide/ |
| H A D | data.rs | 26 .map(|feature| crate::routeguide::Feature { in load()
|
| /tonic/tests/compression/src/ |
| H A D | lib.rs | 72 .map(Ok::<_, Status>); in compress_output_server_stream()
118 .map(Ok::<_, Status>); in compress_input_output_bidirectional_stream()
|
| /tonic/tonic-types/src/richer_error/std_messages/ |
| H A D | help.rs | 128 links: value.links.into_iter().map(Into::into).collect(), in from()
136 links: value.links.into_iter().map(Into::into).collect(), in from()
|
| H A D | bad_request.rs | 132 field_violations: value.field_violations.into_iter().map(Into::into).collect(), in from()
140 field_violations: value.field_violations.into_iter().map(Into::into).collect(), in from()
|
| H A D | quota_failure.rs | 129 violations: value.violations.into_iter().map(Into::into).collect(), in from()
137 violations: value.violations.into_iter().map(Into::into).collect(), in from()
|
| H A D | prec_failure.rs | 152 violations: value.violations.into_iter().map(Into::into).collect(), in from()
160 violations: value.violations.into_iter().map(Into::into).collect(), in from()
|
| /tonic/examples/src/h2c/ |
| H A D | server.rs | 101 let mut req = req.map(Body::new); in call()
105 .map_request(|req: Request<_>| req.map(Body::new)); in call()
|