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

tokio 1.0

Browse source
This commit is contained in:
Robin Appelman 2021-01-20 17:27:31 +01:00
commit f2b0589cf6
4 changed files with 312 additions and 502 deletions
Download patch file Download diff file Expand all files Collapse all files

4
src/main.rs
View file

@ -12,8 +12,8 @@ use dashmap::DashMap;
use pin_utils::pin_mut;
use rumqttc::QoS;
use std::sync::Arc;
use tokio::stream::StreamExt;
use tokio::time::Duration;
use tokio_stream::StreamExt;
use warp::Filter;
type DeviceStates = Arc<DashMap<Device, DeviceState>>;
@ -38,7 +38,7 @@ async fn main() -> Result<()> {
eprintln!("lost mqtt collection: {:#}", e);
}
eprintln!("reconnecting after 1s");
tokio::time::delay_for(Duration::from_secs(1)).await;
tokio::time::sleep(Duration::from_secs(1)).await;
}
});

2
src/mqtt.rs
View file

@ -1,7 +1,7 @@
use async_stream::try_stream;
use color_eyre::Result;
use rumqttc::{AsyncClient, Event, EventLoop, MqttOptions, Packet, Publish, QoS};
use tokio::stream::{Stream, StreamExt};
use tokio_stream::{Stream, StreamExt};
pub async fn mqtt_stream(
mqtt_options: MqttOptions,