tasks: ble: warning--
This commit is contained in:
@@ -89,7 +89,7 @@ struct SerialService {
|
|||||||
async fn client_prediction_task(mut src: DynSubscriber<'static, Prediction>, sink: Publisher<'static, NoopRawMutex, Prediction, 5, 1, 1>) {
|
async fn client_prediction_task(mut src: DynSubscriber<'static, Prediction>, sink: Publisher<'static, NoopRawMutex, Prediction, 5, 1, 1>) {
|
||||||
debug!("Started BLE client prediction stream");
|
debug!("Started BLE client prediction stream");
|
||||||
loop {
|
loop {
|
||||||
sink.publish(src.next_message_pure().await).await;
|
let _ = sink.try_publish(src.next_message_pure().await);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user