fixup! test: PoC deterministic bridge testing

Signed-off-by: James Rhodes <[email protected]>
thin-edge · Feb 17, 2025 · 2b166b6 · 2b166b6
1 parent 17c6cf1
commit 2b166b6
Show file tree

Hide file tree

Showing 3 changed files with 237 additions and 72 deletions.
diff --git a/crates/extensions/tedge_mqtt_bridge/src/health.rs b/crates/extensions/tedge_mqtt_bridge/src/health.rs
@@ -1,6 +1,7 @@
 use crate::overall_status;
 use crate::BridgeAsyncClient;
 use crate::BridgeMessageSender;
+use crate::MqttClient;
 use crate::Status;
 use futures::channel::mpsc;
 use futures::SinkExt;
@@ -25,9 +26,9 @@ pub struct BridgeHealthMonitor {
 }
 
 impl BridgeHealthMonitor {
-    pub(crate) fn new(
+    pub(crate) fn new<C: MqttClient>(
         topic: String,
-        bridge_half: &BridgeAsyncClient,
+        bridge_half: &BridgeAsyncClient<C>,
     ) -> (mpsc::Sender<(&'static str, Status)>, Self) {
         let (tx, rx_status) = mpsc::channel(10);
         (