robin/taspromto
1
0
Fork 0
mirror of https://codeberg.org/icewind/taspromto.git synced 2026-06-03 08:34:21 +02:00
Code Issues Projects Releases Wiki Activity

bump dependencies

Browse source
This commit is contained in:
Robin Appelman 2024-05-07 22:00:16 +02:00
commit f472cc54ef
4 changed files with 241 additions and 215 deletions
Download patch file Download diff file Expand all files Collapse all files

1
src/mqtt.rs
View file

@ -12,6 +12,7 @@ pub async fn mqtt_stream(
client.subscribe("tele/+/SENSOR", QoS::AtMostOnce).await?;
client.subscribe("stat/+/RESULT", QoS::AtMostOnce).await?;
client.subscribe("stat/+/STATUS2", QoS::AtMostOnce).await?;
client.subscribe("rflink/msg", QoS::AtMostOnce).await?;
let stream = event_loop_to_stream(event_loop).filter_map(|event| match event {
Ok(Event::Incoming(Packet::Publish(message))) => Some(Ok(message)),