pub struct CompositeExternalChildRunner { /* private fields */ }Expand description
Composite router that delegates to the first matching external child runner.
Implementations§
Source§impl CompositeExternalChildRunner
impl CompositeExternalChildRunner
pub fn new(runners: Vec<Arc<dyn ExternalChildRunner>>) -> Self
Trait Implementations§
Source§impl ExternalChildRunner for CompositeExternalChildRunner
impl ExternalChildRunner for CompositeExternalChildRunner
Source§fn should_handle<'life0, 'life1, 'async_trait>(
&'life0 self,
session: &'life1 Session,
) -> Pin<Box<dyn Future<Output = bool> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn should_handle<'life0, 'life1, 'async_trait>(
&'life0 self,
session: &'life1 Session,
) -> Pin<Box<dyn Future<Output = bool> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
Returns true if this runner should handle the given child session.
Source§fn execute_external_child<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
session: &'life1 mut Session,
job: &'life2 SpawnJob,
event_tx: Sender<AgentEvent>,
cancel_token: CancellationToken,
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
fn execute_external_child<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
session: &'life1 mut Session,
job: &'life2 SpawnJob,
event_tx: Sender<AgentEvent>,
cancel_token: CancellationToken,
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
Execute the child session using an external runtime.
Auto Trait Implementations§
impl Freeze for CompositeExternalChildRunner
impl !RefUnwindSafe for CompositeExternalChildRunner
impl Send for CompositeExternalChildRunner
impl Sync for CompositeExternalChildRunner
impl Unpin for CompositeExternalChildRunner
impl UnsafeUnpin for CompositeExternalChildRunner
impl !UnwindSafe for CompositeExternalChildRunner
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more