Searched refs:concurrency_limit (Results 1 – 4 of 4) sorted by relevance
| /tonic/tonic/src/transport/server/ |
| H A D | mod.rs | 91 concurrency_limit: Option<usize>, field
115 concurrency_limit: None, in default()
179 concurrency_limit: Some(limit), in concurrency_limit_per_connection()
518 concurrency_limit: self.concurrency_limit, in layer()
647 let concurrency_limit = self.concurrency_limit; in serve_internal() localVariable
673 concurrency_limit, in serve_internal()
1058 concurrency_limit: Option<usize>, field
1086 let concurrency_limit = self.concurrency_limit; in call() localVariable
1092 .option_layer(concurrency_limit.map(ConcurrencyLimitLayer::new)) in call()
|
| /tonic/tonic/src/transport/channel/ |
| H A D | endpoint.rs | 24 pub(crate) concurrency_limit: Option<usize>, field
192 pub fn concurrency_limit(self, limit: usize) -> Self { in concurrency_limit() method
194 concurrency_limit: Some(limit), in concurrency_limit()
450 concurrency_limit: None, in from()
|
| /tonic/interop/src/bin/ |
| H A D | client.rs | 37 .concurrency_limit(30); in main()
|
| /tonic/tonic/src/transport/channel/service/ |
| H A D | connection.rs | 66 .option_layer(endpoint.concurrency_limit.map(ConcurrencyLimitLayer::new)) in new()
|