diff --git a/src/tasks/motion.rs b/src/tasks/motion.rs index c75415f..e100746 100644 --- a/src/tasks/motion.rs +++ b/src/tasks/motion.rs @@ -37,6 +37,8 @@ pub async fn motion_task(src: DynamicReceiver<'static, Measurement>, prediction_ Measurement::SimulationProgress(source, duration, pct) => debug!("{source:?} simulation time: {} {} / 255", duration.as_secs(), pct), Measurement::Annotation => () } - let _ = recording_sink.try_publish(next_measurement); + if recording_sink.try_publish(next_measurement).is_err() { + warn!("Could not publish measurement to recording bus. Is the recording bus stalled?"); + } } } \ No newline at end of file