| /tonic/tests/web/proto/ |
| H A D | test.proto | 6 rpc UnaryCall(Input) returns (Output);
7 rpc ServerStream(Input) returns (stream Output);
8 rpc ClientStream(stream Input) returns (Output);
11 message Input { message
|
| /tonic/tests/integration_tests/tests/ |
| H A D | connection.rs | 1 use integration_tests::pb::{test_client::TestClient, test_server, Input, Output};
14 async fn unary_call(&self, _: Request<Input>) -> Result<Response<Output>, Status> { in unary_call()
60 client.unary_call(Request::new(Input {})).await.unwrap(); in connect_returns_err_via_call_after_connected()
64 let res = client.unary_call(Request::new(Input {})).await; in connect_returns_err_via_call_after_connected()
83 client.unary_call(Request::new(Input {})).await.unwrap_err(); in connect_lazy_reconnects_after_first_failure()
106 client.unary_call(Request::new(Input {})).await.unwrap(); in connect_lazy_reconnects_after_first_failure()
110 let err = client.unary_call(Request::new(Input {})).await.unwrap_err(); in connect_lazy_reconnects_after_first_failure()
|
| H A D | timeout.rs | 1 use integration_tests::pb::{test_client, test_server, Input, Output};
14 let mut req = Request::new(Input {}); in cancelation_on_timeout()
34 let mut req = Request::new(Input {}); in picks_server_timeout_if_thats_sorter()
53 let mut req = Request::new(Input {}); in picks_client_timeout_if_thats_sorter()
71 async fn unary_call(&self, _req: Request<Input>) -> Result<Response<Output>, Status> { in run_service_in_background()
|
| H A D | connect_info.rs | 1 use integration_tests::pb::{test_client, test_server, Input, Output};
18 async fn unary_call(&self, req: Request<Input>) -> Result<Response<Output>, Status> { in getting_connect_info()
53 client.unary_call(Input {}).await.unwrap(); in getting_connect_info()
76 use integration_tests::pb::{test_client, test_server, Input, Output};
82 async fn unary_call(&self, req: Request<Input>) -> Result<Response<Output>, Status> { in unary_call()
129 client.unary_call(Input {}).await.unwrap(); in getting_connect_info()
|
| H A D | http2_keep_alive.rs | 5 use integration_tests::pb::{test_client::TestClient, test_server, Input, Output};
13 async fn unary_call(&self, _: Request<Input>) -> Result<Response<Output>, Status> { in unary_call()
40 let res = client.unary_call(Request::new(Input {})).await; in http2_keepalive_does_not_cause_panics()
76 let res = client.unary_call(Request::new(Input {})).await; in http2_keepalive_does_not_cause_panics_on_client_side()
|
| H A D | user_agent.rs | 1 use integration_tests::pb::{test_client, test_server, Input, Output};
15 async fn unary_call(&self, req: Request<Input>) -> Result<Response<Output>, Status> { in writes_user_agent_header()
51 match client.unary_call(Input {}).await { in writes_user_agent_header()
|
| H A D | interceptor.rs | 1 use integration_tests::pb::{test_client::TestClient, test_server, Input, Output};
17 async fn unary_call(&self, _: Request<Input>) -> Result<Response<Output>, Status> { in interceptor_retrieves_grpc_method()
55 client.unary_call(Request::new(Input {})).await.unwrap(); in interceptor_retrieves_grpc_method()
|
| H A D | http2_max_header_list_size.rs | 3 use integration_tests::pb::{test_client, test_server, Input, Output};
25 async fn unary_call(&self, _: Request<Input>) -> Result<Response<Output>, Status> { in test_http_max_header_list_size_and_long_errors()
63 let err = client.unary_call(Request::new(Input {})).await.unwrap_err(); in test_http_max_header_list_size_and_long_errors()
|
| H A D | client_layer.rs | 2 use integration_tests::pb::{test_client::TestClient, test_server, Input, Output};
18 async fn unary_call(&self, req: Request<Input>) -> Result<Response<Output>, Status> { in connect_supports_standard_tower_layers()
59 client.unary_call(Request::new(Input {})).await.unwrap(); in connect_supports_standard_tower_layers()
|
| H A D | extensions.rs | 2 pb::{test_client, test_server, Input, Output},
27 async fn unary_call(&self, req: Request<Input>) -> Result<Response<Output>, Status> { in setting_extension_from_interceptor()
64 client.unary_call(Input {}).await.unwrap(); in setting_extension_from_interceptor()
77 async fn unary_call(&self, req: Request<Input>) -> Result<Response<Output>, Status> { in setting_extension_from_tower()
113 client.unary_call(Input {}).await.unwrap(); in setting_extension_from_tower()
|
| H A D | origin.rs | 2 use integration_tests::pb::{test_server, Input, Output};
24 _req: tonic::Request<Input>, in writes_origin_header() argument
58 match client.unary_call(Input {}).await { in writes_origin_header()
|
| H A D | routes_builder.rs | 7 test1_client, test1_server, test_client, test_server, Input, Input1, Output, Output1,
23 async fn unary_call(&self, _req: Request<Input>) -> Result<Response<Output>, Status> { in multiple_service_using_routes_builder()
83 client1.unary_call(Input {}).await.unwrap(); in multiple_service_using_routes_builder()
|
| H A D | status.rs | 6 test_client, test_server, test_stream_client, test_stream_server, Input, InputStream, Output,
24 async fn unary_call(&self, _: Request<Input>) -> Result<Response<Output>, Status> { in status_with_details()
56 .unary_call(Request::new(Input {})) in status_with_details()
82 async fn unary_call(&self, _: Request<Input>) -> Result<Response<Output>, Status> { in status_with_metadata()
114 .unary_call(Request::new(Input {})) in status_with_metadata()
|
| H A D | complex_tower_middleware.rs | 4 use integration_tests::pb::{test_server, Input, Output};
19 async fn unary_call(&self, req: Request<Input>) -> Result<Response<Output>, Status> { in complex_tower_layers_work()
|
| /tonic/tests/skip_debug/proto/ |
| H A D | test.proto | 6 rpc Rpc(Input) returns (Output);
9 message Input {} message
|
| /tonic/tests/wellknown-compiled/proto/ |
| H A D | test.proto | 6 message Input { message
10 rpc Call(Input) returns (google.protobuf.Empty);
|
| /tonic/tests/web/src/ |
| H A D | lib.rs | 6 use pb::{test_server::Test, Input, Output};
18 async fn unary_call(&self, req: Request<Input>) -> Result<Response<Output>, Status> { in unary_call()
35 req: Request<Input>, in server_stream() argument
51 req: Request<Streaming<Input>>, in client_stream() argument
|
| /tonic/tests/integration_tests/proto/ |
| H A D | test.proto | 6 rpc UnaryCall(Input) returns (Output);
9 message Input {} message
|
| /tonic/tests/web/tests/ |
| H A D | grpc.rs | 12 use test_web::pb::{test_client::TestClient, test_server::TestServer, Input};
75 let boom = Input { in smoke_error()
144 fn input() -> Input { in input()
145 Input { in input()
|
| H A D | grpc_web.rs | 17 use test_web::pb::{test_server::TestServer, Input, Output};
88 let input = Input { in encode_body()
|