Searched refs:server_streaming (Results 1 – 10 of 10) sorted by relevance
| /tonic/tonic-build/src/ |
| H A D | manual.rs | 175 server_streaming: bool, field
208 fn server_streaming(&self) -> bool { in server_streaming() method
209 self.server_streaming in server_streaming()
270 server_streaming: bool, field
332 pub fn server_streaming(mut self) -> Self { in server_streaming() method
333 self.server_streaming = true; in server_streaming()
348 server_streaming: self.server_streaming, in build()
|
| H A D | client.rs | 184 let method = match (method.client_streaming(), method.server_streaming()) { in generate_methods()
278 self.inner.server_streaming(req, path, codec).await in generate_server_streaming()
|
| H A D | server.rs | 262 method.server_streaming(), in generate_trait_methods()
385 let method_stream = match (method.client_streaming(), method.server_streaming()) { in generate_methods()
552 let res = grpc.server_streaming(method, req).await; in generate_server_streaming()
|
| H A D | lib.rs | 141 fn server_streaming(&self) -> bool; in server_streaming() method
|
| H A D | prost.rs | 155 fn server_streaming(&self) -> bool { in server_streaming() method
156 self.prost_method.server_streaming in server_streaming()
|
| /tonic/interop/src/bin/ |
| H A D | client.rs | 67 client::server_streaming(&mut client, &mut test_results).await in main()
|
| /tonic/tonic-health/src/generated/ |
| H A D | grpc_health_v1.rs | 201 self.inner.server_streaming(req, path, codec).await in watch()
415 let res = grpc.server_streaming(method, req).await; in call()
|
| /tonic/tonic/src/client/ |
| H A D | grpc.rs | 263 pub async fn server_streaming<M1, M2, C>( in server_streaming() method
|
| /tonic/tonic/src/server/ |
| H A D | grpc.rs | 262 pub async fn server_streaming<S, B>( in server_streaming() function
|
| /tonic/interop/src/ |
| H A D | client.rs | 111 pub async fn server_streaming(client: &mut TestClient, assertions: &mut Vec<TestAssertion>) { in server_streaming() function
|