Trait telecomande::Executor

pub trait Executor<P>: Send + 'static where
    P: Processor, {
    fn run<'life0, 'async_trait>(
        &'life0 mut self,
        receiver: UnboundedReceiver<P::Command>
    ) -> Pin<Box<dyn Future<Output = Result<(), P::Error>> + Send + 'async_trait>>
    where
        'life0: 'async_trait,
        Self: 'async_trait;

    fn spawn(self) -> Handle<P>
    where
        Self: Sized,
    { ... }
}

Internal data of a task running and handling incomming crate::Command for a crate::Processor.

Required Methods

fn run<'life0, 'async_trait>(
    &'life0 mut self,
    receiver: UnboundedReceiver<P::Command>
) -> Pin<Box<dyn Future<Output = Result<(), P::Error>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Returns if all crate::Remote and the crate::Handle have been dropped.

Provided Methods

fn spawn(self) -> Handle<P> where
    Self: Sized, 

Creates a tokio task in which an crate::Executor listen for incoming crate::Command.

Implementors

impl<P> Executor<P> for SimpleExecutor<P> where
    P: Processor,