fix: make sure to start mqtt eventloop before returning

1 files changed, 5 insertions, 0 deletions

diff --git a/src/lib.rs b/src/lib.rs
index 70cf1c2..7445ba5 100644
--- a/src/lib.rs
+++ b/src/lib.rs
@@ -4,7 +4,10 @@ mod eventloop;
 mod mqtt;
 mod stridulus_event;
 mod util;
+use std::time::Duration;
+
 use log::{debug, error};
+use tokio::time::sleep;
 use tokio::{sync::mpsc, task};
 
 pub use crate::client::StridulusClient;
@@ -43,6 +46,8 @@ pub async fn create(
     }
   });
 
+  sleep(Duration::from_millis(10)).await; // to make sure the mqtt eventloop is running
+
   Ok((
     StridulusClient {
       client: mqtt_client,