Struct FnHandler 

pub struct FnHandler<J, F> { /* private fields */ }

Blanket adapter so plain async closures can be handlers: builder.handler(FnHandler::<SendEmail, _>::new(|job, ctx| async move { ... })).

Implementations

impl<J, F> FnHandler<J, F>

pub fn new(f: F) -> Self

Wrap f as a JobHandler for job type J.

Trait Implementations

impl<J, F, Fut> JobHandler for FnHandler<J, F>

where J: Job, F: Fn(J, JobContext) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<(), JobError>> + Send + 'static,

type Job = J

The one job type this handler processes.

fn handle<'life0, 'async_trait>( &'life0 self, job: J, ctx: JobContext, ) -> Pin<Box<dyn Future<Output = Result<(), JobError>> + Send + 'async_trait>>

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

Process one job. Returning Err hands control to the retry policy.