Lines Matching refs:client
21 pub async fn empty_unary(client: &mut TestClient, assertions: &mut Vec<TestAssertion>) { in empty_unary()
22 let result = client.empty_call(Request::new(Empty {})).await; in empty_unary()
40 pub async fn large_unary(client: &mut TestClient, assertions: &mut Vec<TestAssertion>) { in large_unary()
50 let result = client.unary_call(Request::new(req)).await; in large_unary()
84 pub async fn client_streaming(client: &mut TestClient, assertions: &mut Vec<TestAssertion>) { in client_streaming()
92 let result = client.streaming_input_call(Request::new(stream)).await; in client_streaming()
111 pub async fn server_streaming(client: &mut TestClient, assertions: &mut Vec<TestAssertion>) { in server_streaming()
121 let result = client.streaming_output_call(req).await; in server_streaming()
153 pub async fn ping_pong(client: &mut TestClient, assertions: &mut Vec<TestAssertion>) { in ping_pong()
157 let result = client in ping_pong()
209 pub async fn empty_stream(client: &mut TestClient, assertions: &mut Vec<TestAssertion>) { in empty_stream()
211 let result = client.full_duplex_call(Request::new(stream)).await; in empty_stream()
230 pub async fn status_code_and_message(client: &mut TestClient, assertions: &mut Vec<TestAssertion>) { in status_code_and_message()
270 let result = client.unary_call(Request::new(simple_req)).await; in status_code_and_message()
274 let result = match client.full_duplex_call(Request::new(stream)).await { in status_code_and_message()
286 pub async fn special_status_message(client: &mut TestClient, assertions: &mut Vec<TestAssertion>) { in special_status_message()
295 let result = client.unary_call(Request::new(req)).await; in special_status_message()
316 pub async fn unimplemented_method(client: &mut TestClient, assertions: &mut Vec<TestAssertion>) { in unimplemented_method()
317 let result = client.unimplemented_call(Request::new(Empty {})).await; in unimplemented_method()
329 client: &mut UnimplementedClient, in unimplemented_service()
332 let result = client.unimplemented_call(Request::new(Empty {})).await; in unimplemented_service()
343 pub async fn custom_metadata(client: &mut TestClient, assertions: &mut Vec<TestAssertion>) { in custom_metadata()
364 let response = client in custom_metadata()
380 let response = client in custom_metadata()