diff --git a/src/tasks/ble.rs b/src/tasks/ble.rs index 2badcda..eefc452 100644 --- a/src/tasks/ble.rs +++ b/src/tasks/ble.rs @@ -89,7 +89,7 @@ struct SerialService { async fn client_prediction_task(mut src: DynSubscriber<'static, Prediction>, sink: Publisher<'static, NoopRawMutex, Prediction, 5, 1, 1>) { debug!("Started BLE client prediction stream"); loop { - sink.publish(src.next_message_pure().await).await; + let _ = sink.try_publish(src.next_message_pure().await); } }