Impl Default for ClientHandlers

Signed-off-by: Matthias Beyer <mail@beyermatthias.de>

2 files changed, 11 insertions, 4 deletions

diff --git a/src/client/mod.rs b/src/client/mod.rs
index 72780b3..bd46b51 100644
--- a/src/client/mod.rs
+++ b/src/client/mod.rs
@@ -36,10 +36,7 @@ impl MqttClient {
             inner: Arc::new(Mutex::new(InnerClient {
                 connection_state: None,
                 session_state: None,
-                default_handlers: ClientHandlers {
-                    on_packet_recv: Box::new(|_| ()),
-                    handle_acknowledge: Box::new(|_| Acknowledge::Yes),
-                },
+                default_handlers: ClientHandlers::default(),
                 outstanding_callbacks: Callbacks::new(),
             })),
         }
diff --git a/src/client/send.rs b/src/client/send.rs
index 01a512e..319412b 100644
--- a/src/client/send.rs
+++ b/src/client/send.rs
@@ -7,6 +7,7 @@
 use std::collections::HashMap;
 use std::collections::VecDeque;
 
+use futures::FutureExt;
 use mqtt_format::v5::integers::VARIABLE_INTEGER_MAX;
 use mqtt_format::v5::packets::publish::MPublish;
 use tracing::Instrument;
@@ -225,6 +226,15 @@ pub type HandleAcknowledgeFn = Box<
         + Send,
 >;
 
+impl Default for ClientHandlers {
+    fn default() -> Self {
+        Self {
+            on_packet_recv: Box::new(|_| ()),
+            handle_acknowledge: Box::new(|_| async move { Acknowledge::Yes }.boxed()),
+        }
+    }
+}
+
 #[derive(Debug)]
 pub enum Acknowledge {
     No,