pub fn runner(self, pool: &Pool<Postgres>) -> JobRunnerOptions {
        JobRunnerOptions::new(pool, move |current_job| {
            if let Some(job) = self.resolve_job(current_job.name()) {
                (job.run_fn.0 .0)(&self, current_job);
            } else {
                (self.error_handler)(current_job.name(), Box::new(UnknownJobError))
            }
        })
    }
/// Construct a job runner from this registry and the provided connection
/// pool.
Construct a job runner from this registry and the provided connection
pool.
Construct a job runner from this registry and the provided connection pool .
pub fn runner(self, pool: &Pool<Postgres>) -> JobRunnerOptions {
        JobRunnerOptions::new(pool, move |current_job| {
            if let Some(job) = self.resolve_job(current_job.name()) {
                (job.run_fn.0 .0)(&self, current_job);
            } else {
                (self.error_handler)(current_job.name(), Box::new(UnknownJobError))
            }
        })
    }
pub fn runner ( self , pool : & Pool < Postgres > ) -> JobRunnerOptions { JobRunnerOptions :: new ( pool , move | current_job | { if let Some ( job ) = self . resolve_job ( current_job . name ( ) ) { ( job . run_fn . 0 . 0 ) ( & self , current_job ) ; } else { ( self . error_handler ) ( current_job . name ( ) , Box :: new ( UnknownJobError ) ) } } ) }
Construct a job runner from this registry and the provided connection
pool.
Construct a job runner from this registry and the provided connection pool .
self
pool
&Pool<Postgres>
self
pool
&Pool<Postgres>