Wrap passthru in mutex

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "zika"
-version = "3.3.0"
+version = "3.3.1"
 license = "MIT"
 description = "IP Tunneling over MQTT"
 repository = "https://github.com/akiroz/zika"

src/client.rs

@@ -24,7 +24,7 @@ pub struct Client {
     pub local_addr: Ipv4Addr,
     tunnels: Arc<Vec<Tunnel>>,
     pub remote: Arc<Mutex<remote::Remote>>, // Allow external mqtt ops
-    pub remote_passthru_recv: broadcast::Receiver<(String, Bytes)>,
+    pub remote_passthru_recv: Arc<Mutex<broadcast::Receiver<(String, Bytes)>>>,
 }
 
 struct Tunnel {
@@ -100,7 +100,7 @@ impl Client {
             local_addr,
             tunnels: Arc::new(tunnels),
             remote: Arc::new(Mutex::new(remote)),
-            remote_passthru_recv,
+            remote_passthru_recv: Arc::new(Mutex::new(remote_passthru_recv)),
         });
 
         let loop_client = client.clone();

src/remote.rs

@@ -1,12 +1,11 @@
-use bytes::Bytes;
 use log;
+use bytes::Bytes;
 use rumqttc::v5::{
     self as mqtt,
     mqttbytes::{v5::Packet, QoS},
 };
 use std::sync::Arc;
-use tokio::sync::Mutex;
-use tokio::{sync::mpsc, task};
+use tokio::{sync::{mpsc, Mutex}, task};
 
 use crate::lookup_pool::LookupPool;
 use rumqttc::v5::mqttbytes::v5::PublishProperties;