Home
last modified time | relevance | path

Searched refs:response (Results 1 – 25 of 71) sorted by relevance

123

/tonic/interop/src/
H A Dclient.rs30 if let Ok(response) = result { in empty_unary()
31 let body = response.into_inner(); in empty_unary()
58 if let Ok(response) = result { in large_unary()
59 let body = response.into_inner(); in large_unary()
100 if let Ok(response) = result { in client_streaming()
101 let body = response.into_inner(); in client_streaming()
129 if let Ok(response) = result { in server_streaming()
130 let responses = response in server_streaming()
275 Ok(response) => { in status_code_and_message()
364 let response = client in custom_metadata() localVariable
[all …]
/tonic/examples/src/cancellation/
H A Dclient.rs19 let response = match timeout(Duration::from_secs(1), client.say_hello(request)).await { in main() localVariable
20 Ok(response) => response?, in main()
27 println!("RESPONSE={:?}", response); in main()
/tonic/examples/src/richer-error/
H A Dclient.rs23 let response = match client.say_hello(request).await { in main() localVariable
24 Ok(response) => response, in main()
49 println!(" Successful response received.\n\n {:?}\n", response); in main()
H A Dclient_vec.rs23 let response = match client.say_hello(request).await { in main() localVariable
24 Ok(response) => response, in main()
55 println!(" Successful response received.\n\n {:?}\n", response); in main()
/tonic/examples/src/multiplex/
H A Dclient.rs26 let response = greeter_client.say_hello(request).await?; in main() localVariable
28 println!("GREETER RESPONSE={:?}", response); in main()
34 let response = echo_client.unary_echo(request).await?; in main() localVariable
36 println!("ECHO RESPONSE={:?}", response); in main()
/tonic/tonic-reflection/tests/
H A Dserver.rs29 let response = make_test_reflection_request(ServerReflectionRequest { in test_list_services() localVariable
35 if let MessageResponse::ListServicesResponse(services) = response { in test_list_services()
49 let response = make_test_reflection_request(ServerReflectionRequest { in test_file_by_filename() localVariable
57 if let MessageResponse::FileDescriptorResponse(descriptor) = response { in test_file_by_filename()
73 let response = make_test_reflection_request(ServerReflectionRequest { in test_file_containing_symbol() localVariable
81 if let MessageResponse::FileDescriptorResponse(descriptor) = response { in test_file_containing_symbol()
135 let response = inbound in make_test_reflection_request() localVariable
150 response in make_test_reflection_request()
H A Dversions.rs14 let response = make_v1_request(v1::ServerReflectionRequest { in test_v1() localVariable
23 response in test_v1()
38 let response = make_v1alpha_request(v1alpha::ServerReflectionRequest { in test_v1alpha() localVariable
47 response in test_v1alpha()
99 let response = inbound in make_v1_request() localVariable
114 response in make_v1_request()
156 let response = inbound in make_v1alpha_request() localVariable
171 response in make_v1alpha_request()
/tonic/tonic/src/server/
H A Dgrpc.rs246 let response = service in unary() localVariable
254 response, in unary()
290 let response = service.call(request).await; in server_streaming() localVariable
293 response, in server_streaming()
320 let response = service in client_streaming() localVariable
328 response, in client_streaming()
354 let response = service.call(request).await; in streaming() localVariable
357 response, in streaming()
429 let response = t!(response); in map_response() localVariable
490 .and_then(|response| { in compression_override_from_response()
[all …]
/tonic/interop/proto/grpc/testing/
H A Dmessages.proto55 // Desired payload type in the response from the server.
59 // Desired payload size in the response from the server.
74 // the response's compression status.
84 // Unary response, as configured by the request.
106 // Not expecting any payload from the response.
109 // Client-streaming response.
115 // Configuration for a particular response.
127 // the response's compression status.
134 // Desired payload type in the response from the server.
140 // Configuration for each expected response message.
[all …]
/tonic/examples/src/routeguide/
H A Dclient.rs54 Ok(response) => println!("SUMMARY: {:?}", response.into_inner()), in run_record_route()
82 let response = client.route_chat(Request::new(outbound)).await?; in run_route_chat() localVariable
83 let mut inbound = response.into_inner(); in run_route_chat()
97 let response = client in main() localVariable
103 println!("RESPONSE = {:?}", response); in main()
/tonic/examples/src/tracing/
H A Dclient.rs29 let response = client.say_hello(request).await?; in say_hi() localVariable
33 response = %response.get_ref().message in say_hi()
/tonic/examples/src/streaming/
H A Dclient.rs37 let response = client in bidirectional_streaming_echo() localVariable
42 let mut resp_stream = response.into_inner(); in bidirectional_streaming_echo()
53 let response = client in bidirectional_streaming_echo_throttle() localVariable
58 let mut resp_stream = response.into_inner(); in bidirectional_streaming_echo_throttle()
/tonic/examples/src/helloworld/
H A Dclient.rs16 let response = client.say_hello(request).await?; in main() localVariable
18 println!("RESPONSE={:?}", response); in main()
/tonic/examples/src/tower/
H A Dclient.rs28 let response = client.say_hello(request).await?; in main() localVariable
30 println!("RESPONSE={:?}", response); in main()
77 let response = inner.call(req).await?; in call() localVariable
79 Ok(response) in call()
/tonic/examples/src/codec_buffers/
H A Dclient.rs25 let response = client.say_hello(request).await?; in main() localVariable
27 println!("RESPONSE={:?}", response); in main()
/tonic/examples/src/json-codec/
H A Dclient.rs23 let response = client.say_hello(request).await?; in main() localVariable
25 println!("RESPONSE={:?}", response); in main()
/tonic/examples/src/load_balance/
H A Dclient.rs23 let response = client.unary_echo(request).await?; in main() localVariable
25 println!("RESPONSE={:?}", response); in main()
/tonic/examples/src/compression/
H A Dclient.rs25 let response = client.say_hello(request).await?; in main() localVariable
27 dbg!(response); in main()
/tonic/examples/src/authentication/
H A Dclient.rs23 let response = client.unary_echo(request).await?; in main() localVariable
25 println!("RESPONSE={:?}", response); in main()
/tonic/examples/src/grpc-web/
H A Dclient.rs24 let response = client.say_hello(request).await?; in main() localVariable
26 println!("RESPONSE={:?}", response); in main()
/tonic/tonic/src/client/
H A Dgrpc.rs310 let response = self in streaming() localVariable
318 self.create_response(decoder, response) in streaming()
326 response: http::Response<T::ResponseBody>, in create_response()
334 response.headers(), in create_response()
338 let status_code = response.status(); in create_response()
339 let trailers_only_status = Status::from_header_map(response.headers()); in create_response()
353 let response = response.map(|body| { in create_response() localVariable
367 Ok(Response::from_http(response)) in create_response()
/tonic/examples/src/tls/
H A Dclient.rs28 let response = client.unary_echo(request).await?; in main() localVariable
30 println!("RESPONSE={:?}", response); in main()
/tonic/tonic/src/
H A Dlib.rs111 mod response; module
124 pub use response::Response;
/tonic/examples/src/uds/
H A Dclient.rs36 let response = client.say_hello(request).await?; in main() localVariable
38 println!("RESPONSE={:?}", response); in main()
/tonic/examples/src/tls_client_auth/
H A Dclient.rs33 let response = client.unary_echo(request).await?; in main() localVariable
35 println!("RESPONSE={:?}", response); in main()

123