Home
last modified time | relevance | path

Searched refs:r (Results 1 – 12 of 12) sorted by relevance

/tonic/tonic-types/src/richer_error/std_messages/
H A Dprec_failure.rs17 pub r#type: String,
29 r#type: impl Into<String>, in new()
34 r#type: r#type.into(), in new()
44 r#type: value.r#type, in from()
54 r#type: value.r#type, in from()
92 r#type: violation_type.into(), in with_violation()
103 r#type: impl Into<String>, in add_violation()
108 r#type: r#type.into(), in add_violation()
/tonic/tonic/src/server/
H A Dgrpc.rs235 Ok(r) => r, in unary()
249 .map(|r| r.map(|m| tokio_stream::once(Ok(m)))); in unary()
279 Ok(r) => r, in server_streaming()
323 .map(|r| r.map(|m| tokio_stream::once(Ok(m)))); in client_streaming()
/tonic/tonic/src/
H A Dresponse.rs143 let mut r = Response::new(1); in reserved_headers_are_excluded() localVariable
146 r.metadata_mut().insert( in reserved_headers_are_excluded()
152 let http_response = r.into_http(); in reserved_headers_are_excluded()
H A Drequest.rs447 let mut r = Request::new(1); in reserved_headers_are_excluded() localVariable
450 r.metadata_mut().insert( in reserved_headers_are_excluded()
456 let http_request = r.into_http( in reserved_headers_are_excluded()
/tonic/tests/web/tests/
H A Dgrpc.rs151 fn meta<T>(r: &Response<T>) -> String { in meta()
152 format!("{:?}", r.metadata()) in meta()
155 fn data<T>(r: &Response<T>) -> &T { in data()
156 r.get_ref() in data()
159 async fn stream<T>(r: Response<Streaming<T>>) -> Vec<T> { in stream()
160 r.into_inner().collect::<Result<Vec<_>, _>>().await.unwrap() in stream()
/tonic/tonic-web/src/
H A Dclient.rs98 Poll::Ready(res.map(|r| r.map(GrpcWebCall::client_response))) in poll()
/tonic/interop/src/
H A Dlib.rs20 r#type: default::Default::default(), in client_payload()
27 r#type: default::Default::default(), in server_payload()
/tonic/tonic/src/transport/channel/service/
H A Dreconnect.rs74 Poll::Ready(r) => r?, in poll_ready()
/tonic/tonic/src/codec/
H A Dprost.rs239 while let Some(r) = body.frame().await { in encode()
240 r.unwrap(); in encode()
/tonic/tonic-types/src/generated/
H A Dgoogle_rpc.rs170 pub r#type: ::prost::alloc::string::String,
/tonic/tonic/src/metadata/
H A Dmap.rs267 for r in &Self::GRPC_RESERVED_HEADERS { in into_sanitized_headers()
268 self.headers.remove(r); in into_sanitized_headers()
/tonic/examples/data/gcp/
H A Droots.pem540 r/OSmbaz5mEP0oUA51Aa5BuVnRmhuZyxm7EAHu/QD09CbMkKvO5D+jpxpchNJqU1