Searched refs:executor (Results 1 – 5 of 5) sorted by relevance
| /tonic/tonic/src/transport/channel/ |
| H A D | mod.rs | 136 executor: E, in balance_channel_with_executor()
144 (Self::balance(list, DEFAULT_BUFFER_SIZE, executor), tx) in balance_channel_with_executor()
158 let executor = endpoint.executor.clone(); in new() localVariable
163 executor.execute(worker); in new()
179 let executor = endpoint.executor.clone(); in connect() localVariable
185 executor.execute(worker); in connect()
190 pub(crate) fn balance<D, E>(discover: D, buffer_size: usize, executor: E) -> Self in balance()
201 executor.execute(Box::pin(worker)); in balance()
|
| H A D | endpoint.rs | 40 pub(crate) executor: SharedExec, field
313 pub fn executor<E>(mut self, executor: E) -> Self in executor() method
317 self.executor = SharedExec::new(executor); in executor()
466 executor: SharedExec::tokio(), in from()
|
| /tonic/tonic/src/transport/channel/service/ |
| H A D | mod.rs | 23 mod executor; module
24 pub(super) use self::executor::{Executor, SharedExec};
|
| H A D | connection.rs | 35 let mut settings: Builder<SharedExec> = Builder::new(endpoint.executor.clone()) in new()
71 MakeSendRequestService::new(connector, endpoint.executor.clone(), settings); in new()
160 executor: SharedExec, field
165 fn new(connector: C, executor: SharedExec, settings: Builder<SharedExec>) -> Self { in new()
168 executor, in new()
192 let executor = self.executor.clone(); in call() localVariable
199 &executor, in call()
|
| /tonic/ |
| H A D | CHANGELOG.md | 299 * **transport:** support customizing `Channel`'s async executor ([#935](https://github.com/hyperium…
|