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");
}
}
}