Home
last modified time | relevance | path

Searched refs:s (Results 1 – 25 of 46) sorted by relevance

12

/tonic/tests/deprecated_methods/tests/
H A Ddeprecated_methods.rs6 let s = fs::read_to_string(path) in test() localVariable
11 assert!(s.contains("#[deprecated] pub async fn deprecated(")); in test()
12 assert!(!s.contains("#[deprecated] pub async fn not_deprecated(")); in test()
/tonic/tests/disable_comments/tests/
H A Ddisable_comments.rs6 let s = fs::read_to_string(path).unwrap(); in test() localVariable
7 assert!(!s.contains("This comment will be removed.")); in test()
10 while let Some(found) = s[index..].find("This comment will not be removed.") { in test()
/tonic/tests/skip_debug/tests/
H A Dskip_debug.rs6 let s = fs::read_to_string(path).unwrap(); in skip_debug() localVariable
7 assert!(s.contains("#[prost(skip_debug)]\npub struct Output {}")); in skip_debug()
/tonic/tonic-reflection/src/server/
H A Dv1alpha.rs44 MessageRequest::FileByFilename(s) => state.file_by_filename(&s).map(|fd| { in server_reflection_info()
49 MessageRequest::FileContainingSymbol(s) => { 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 Dv1.rs44 MessageRequest::FileByFilename(s) => state.file_by_filename(&s).map(|fd| { in server_reflection_info()
49 MessageRequest::FileContainingSymbol(s) => { 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/benches-disabled/
H A DREADME.md24 thrpt: [33.298 GiB/s 33.758 GiB/s 34.200 GiB/s]
/tonic/tonic-health/src/
H A Dlib.rs69 fn from(s: ServingStatus) -> Self { in from()
70 match s { in from()
/tonic/tonic/src/transport/channel/service/
H A Dconnection.rs59 .layer_fn(|s| { in new()
62 AddOrigin::new(s, origin) in new()
64 .layer_fn(|s| UserAgent::new(s, endpoint.user_agent.clone())) in new()
65 .layer_fn(|s| GrpcTimeout::new(s, endpoint.timeout)) in new()
/tonic/tests/integration_tests/tests/
H A Dstreams.rs21 let s = Unsync(std::ptr::null_mut::<()>()); in status_from_server_stream_with_source() localVariable
23 Ok(Response::new(Box::pin(s) as Self::StreamCallStream)) in status_from_server_stream_with_source()
H A Dstatus.rs156 let s = tokio_stream::iter(vec![ in status_from_server_stream() localVariable
160 Ok(Response::new(Box::pin(s) as Self::StreamCallStream)) in status_from_server_stream()
226 let s = tokio_stream::iter(vec![ in message_and_then_status_from_server_stream() localVariable
230 Ok(Response::new(Box::pin(s) as Self::StreamCallStream)) in message_and_then_status_from_server_stream()
/tonic/examples/src/tls_rustls/
H A Dclient.rs38 .layer_fn(move |s| { in main()
45 .wrap_connector(s) in main()
/tonic/tonic/src/transport/channel/
H A Dendpoint.rs71 pub fn from_static(s: &'static str) -> Self { in from_static()
72 let uri = Uri::from_static(s); in from_static()
82 pub fn from_shared(s: impl Into<Bytes>) -> Result<Self, Error> { in from_shared()
83 let uri = Uri::from_maybe_shared(s.into()).map_err(|e| Error::new_invalid_uri().with(e))?; in from_shared()
505 fn from_str(s: &str) -> Result<Self, Self::Err> { in from_str()
506 Self::try_from(s.to_string()) in from_str()
H A Dmod.rs89 pub fn from_static(s: &'static str) -> Endpoint { in from_static()
90 let uri = Uri::from_static(s); in from_static()
100 pub fn from_shared(s: impl Into<Bytes>) -> Result<Endpoint, InvalidUri> { in from_shared()
101 let uri = Uri::from_maybe_shared(s.into())?; in from_shared()
/tonic/tonic/src/codec/
H A Dcompression.rs161 Ok(s) => s, in from_encoding_header()
205 fn split_by_comma(s: &str) -> impl Iterator<Item = &str> { in split_by_comma()
206 s.split(',').map(|s| s.trim()) in split_by_comma()
/tonic/examples/src/h2c/
H A Dserver.rs44 let h2c = h2c::H2c { s: svc }; in main()
77 pub s: S, field
103 .s in call()
/tonic/tonic/src/metadata/
H A Dvalue.rs347 fn try_from(s: &'a str) -> Result<Self, Self::Error> { in try_from()
348 s.parse() in try_from()
362 fn try_from(s: &'a String) -> Result<Self, Self::Error> { in try_from()
363 s.parse() in try_from()
377 fn try_from(s: String) -> Result<Self, Self::Error> { in try_from()
378 s.parse() in try_from()
572 fn from_str(s: &str) -> Result<MetadataValue<Ascii>, Self::Err> { in from_str()
573 HeaderValue::from_str(s) in from_str()
809 fn from_str<VE: ValueEncoding>(s: &str) -> MetadataValue<VE> { in test_is_empty()
810 MetadataValue::<VE>::unchecked_from_header_value(s.parse().unwrap()) in test_is_empty()
/tonic/examples/
H A Drouteguide-tutorial.md39 Clone or download Tonic's repository:
45 Change your current directory to Tonic's repository root:
85 [protocol buffers]. We will keep our `.proto` files in a directory in our crate's root.
204 That's it. The generated code contains:
247 We can use Tonic's `include_proto` macro to bring the generated code into scope:
335 **Note:** If you are following along, you'll need to change the data file's path from
395 need to send back multiple `Feature`s to our client.
419 Like `get_feature`, `list_features`'s input is a single message, a `Rectangle` in this
428 Now let's look at something a little more complicated: the client-side streaming method
479 of `RouteNote`s and returns a stream of `RouteNote`s.
[all …]
H A Dhelloworld-tutorial.md34 [protocol buffers]. We will keep our `.proto` files in a directory in our project's root.
98 …uf for our application we can start writing our application with Tonic! Let's first add our requir…
155 Next up, let's implement the Greeter service we previously defined in our `.proto` file. Here's wha…
178 Finally, let's define the Tokio runtime that our server will actually run on. This requires Tokio t…
260 So now we have a running gRPC server, and that's great but how can our application communicate with…
290 That's it! Our complete client file should look something like below, if it doesn't please go back …
/tonic/tonic-build/src/
H A Dlib.rs319 let mut s = String::new(); in naive_snake_case() localVariable
323 s.push(x.to_ascii_lowercase()); in naive_snake_case()
326 s.push('_'); in naive_snake_case()
331 s in naive_snake_case()
/tonic/interop/data/
H A DREADME.md3 This directory contains certificates used for testing interop between Tonic's
/tonic/tonic/src/transport/service/
H A Dgrpc_timeout.rs113 .and_then(|s| if s.is_empty() { Err(val) } else { Ok(s) })? in try_parse_grpc_timeout()
/tonic/tests/web/tests/
H A Dgrpc.rs163 fn status(s: &tonic::Status) -> (String, tonic::Code) { in status()
164 (format!("{:?}", s.metadata()), s.code()) in status()
/tonic/.github/ISSUE_TEMPLATE/
H A Dfeature_request.md19 Please describe the use case(s) or other motivation for the new feature.
/tonic/tonic-health/proto/
H A Dhealth.proto50 // the service's serving status changes.
56 // server will send a new message with the service's serving status.
/tonic/tonic/benches-disabled/proto/helloworld/
H A Dhelloworld.proto29 // The request message containing the user's name.

12