pub fn new<F: Fn(CurrentJob) + Send + Sync + 'static>(pool: &Pool<Postgres>, f: F) -> Self {
        Self {
            min_concurrency: 16,
            max_concurrency: 32,
            channel_names: None,
            keep_alive: true,
            dispatch: Opaque(Arc::new(f)),
            pool: pool.clone(),
        }
    }
/// Begin constructing a new job runner using the specified connection pool,
/// and the provided execution function.
Begin constructing a new job runner using the specified connection pool,
and the provided execution function.
Begin constructing a new job runner using the specified connection pool and the provided execution function .
pub fn new<F: Fn(CurrentJob) + Send + Sync + 'static>(pool: &Pool<Postgres>, f: F) -> Self {
        Self {
            min_concurrency: 16,
            max_concurrency: 32,
            channel_names: None,
            keep_alive: true,
            dispatch: Opaque(Arc::new(f)),
            pool: pool.clone(),
        }
    }
pub fn new < F : Fn ( CurrentJob ) + Send + Sync + ' static > ( pool : & Pool < Postgres > , f : F ) -> Self { Self { min_concurrency : 16 , max_concurrency : 32 , channel_names : None , keep_alive : true , dispatch : Opaque ( Arc :: new ( f ) ) , pool : pool . clone ( ) , } }
Begin constructing a new job runner using the specified connection pool,
and the provided execution function.
Begin constructing a new job runner using the specified connection pool and the provided execution function .
pool
&Pool<Postgres>
f
F
pool
&Pool<Postgres>
f
F