Searched refs:SharedExec (Results 1 – 5 of 5) sorted by relevance
| /tonic/tonic/src/transport/channel/service/ |
| H A D | executor.rs | 8 pub(crate) struct SharedExec { struct
12 impl SharedExec { argument
27 impl<F> Executor<F> for SharedExec implementation
|
| H A D | connection.rs | 1 use super::{AddOrigin, Reconnect, SharedExec, UserAgent};
35 let mut settings: Builder<SharedExec> = Builder::new(endpoint.executor.clone()) in new()
160 executor: SharedExec,
161 settings: Builder<SharedExec>,
165 fn new(connector: C, executor: SharedExec, settings: Builder<SharedExec>) -> Self { in new() argument
|
| H A D | mod.rs | 24 pub(super) use self::executor::{Executor, SharedExec};
|
| /tonic/tonic/src/transport/channel/ |
| H A D | endpoint.rs | 3 use super::service::{self, Executor, SharedExec};
40 pub(crate) executor: SharedExec,
317 self.executor = SharedExec::new(executor); in executor()
466 executor: SharedExec::tokio(), in from()
|
| H A D | mod.rs | 13 use self::service::{Connection, DynamicServiceStream, Executor, SharedExec};
126 Self::balance_channel_with_executor(capacity, SharedExec::tokio()) in balance_channel()
|