Trait ExecutionHandler

pub trait ExecutionHandler<J>
where
    J: JobType,
{
    // Required method
    fn execute<'life0, 'async_trait>(
        &'life0 self,
        context: ExecutionContext,
        input: J,
    ) -> Pin<Box<dyn Future<Output = Result<<J as JobType>::Output, Report>> + Send + 'async_trait>>
       where 'life0: 'async_trait,
             Self: 'async_trait;

    // Provided method
    fn raw_handler(self) -> Arc<dyn ExecutionHandlerRaw + Sync + Send>
       where Self: Sized + Send + Sync + 'static { ... }
}

An execution handler for a specific job type.

Required Methods

fn execute<'life0, 'async_trait>( &'life0 self, context: ExecutionContext, input: J, ) -> Pin<Box<dyn Future<Output = Result<<J as JobType>::Output, Report>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

Execute the given job execution.

Provided Methods

fn raw_handler(self) -> Arc<dyn ExecutionHandlerRaw + Sync + Send>

where Self: Sized + Send + Sync + 'static,

Return a raw handler to be used by an executor.

Implementors

impl<J, F, Fut> ExecutionHandler<J> for F

where J: JobType, F: Fn(ExecutionContext, J) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<<J as JobType>::Output, Report>> + Send + 'static,