fn spawn()

in src/samplers/rezolus/mod.rs [56:70]


    fn spawn(common: Common) {
        if common.config().samplers().rezolus().enabled() {
            if let Ok(mut sampler) = Self::new(common.clone()) {
                common.runtime().spawn(async move {
                    loop {
                        let _ = sampler.sample().await;
                    }
                });
            } else if !common.config.fault_tolerant() {
                fatal!("failed to initialize rezolus sampler");
            } else {
                error!("failed to initialize rezolus sampler");
            }
        }
    }