Searched refs:SomeData (Results 1 – 9 of 9) sorted by relevance
| /tonic/tests/compression/proto/ |
| H A D | test.proto | 8 rpc CompressOutputUnary(google.protobuf.Empty) returns (SomeData);
9 rpc CompressInputUnary(SomeData) returns (google.protobuf.Empty);
10 rpc CompressOutputServerStream(google.protobuf.Empty) returns (stream SomeData);
11 rpc CompressInputClientStream(stream SomeData) returns (google.protobuf.Empty);
12 rpc CompressOutputClientStream(stream SomeData) returns (SomeData);
13 rpc CompressInputOutputBidirectionalStream(stream SomeData) returns (stream SomeData);
16 message SomeData { message
|
| /tonic/tests/compression/src/ |
| H A D | lib.rs | 52 Ok(self.prepare_response(Response::new(SomeData { in compress_output_unary()
57 async fn compress_input_unary(&self, req: Request<SomeData>) -> Result<Response<()>, Status> { in compress_input_unary()
63 Pin<Box<dyn Stream<Item = Result<SomeData, Status>> + Send + 'static>>;
70 let stream = tokio_stream::iter(std::iter::repeat(SomeData { data })) in compress_output_server_stream()
78 req: Request<Streaming<SomeData>>, in compress_input_client_stream() argument
89 req: Request<Streaming<SomeData>>, in compress_output_client_stream() argument
90 ) -> Result<Response<SomeData>, Status> { in compress_output_client_stream() argument
98 Ok(self.prepare_response(Response::new(SomeData { in compress_output_client_stream()
104 Pin<Box<dyn Stream<Item = Result<SomeData, Status>> + Send + 'static>>;
108 req: Request<Streaming<SomeData>>, in compress_input_output_bidirectional_stream() argument
[all …]
|
| H A D | client_stream.rs | 69 let stream = tokio_stream::iter(vec![SomeData { data: data.clone() }, SomeData { data }]); in client_enabled_server_enabled()
120 let stream = tokio_stream::iter(vec![SomeData { data: data.clone() }, SomeData { data }]); in client_disabled_server_enabled()
154 let stream = tokio_stream::iter(vec![SomeData { data: data.clone() }, SomeData { data }]); in client_enabled_server_disabled()
|
| H A D | bidirectional_stream.rs | 80 let stream = tokio_stream::iter(vec![SomeData { data: data.clone() }, SomeData { data }]); in client_enabled_server_enabled()
96 let mut stream: Streaming<SomeData> = res.into_inner(); in client_enabled_server_enabled()
|
| H A D | compressing_request.rs | 72 .compress_input_unary(SomeData { in client_enabled_server_enabled()
134 .compress_input_unary(SomeData { in client_enabled_server_enabled_multi_encoding()
169 .compress_input_unary(SomeData { in client_enabled_server_disabled()
228 .compress_input_unary(SomeData { in client_mark_compressed_without_header_server_enabled()
|
| H A D | server_stream.rs | 54 let mut stream: Streaming<SomeData> = res.into_inner(); in client_enabled_server_enabled()
112 let mut stream: Streaming<SomeData> = res.into_inner(); in client_disabled_server_enabled()
165 let mut stream: Streaming<SomeData> = res.into_inner(); in client_enabled_server_disabled()
|
| H A D | compressing_response.rs | 418 let mut stream: Streaming<SomeData> = res.into_inner(); in disabling_compression_on_response_but_keeping_compression_on_stream()
|
| /tonic/tests/use_arc_self/proto/ |
| H A D | test.proto | 6 rpc TestRequest(SomeData) returns (SomeData);
9 message SomeData { message
|
| /tonic/tests/use_arc_self/src/ |
| H A D | lib.rs | 16 req: Request<SomeData>, in test_request() argument
17 ) -> Result<Response<SomeData>, Status> { in test_request() argument
|