diff options
author | Matthias Beyer <mail@beyermatthias.de> | 2024-04-05 11:35:52 +0200 |
---|---|---|
committer | Matthias Beyer <mail@beyermatthias.de> | 2024-04-05 11:41:24 +0200 |
commit | 0a9f156717d8b32876df0d4e435ac8198b080012 (patch) | |
tree | 90aa4c92b66d7ccea7f6e67d6b8f002dc0df29de | |
parent | 34f95c5a787175e89821e83075962593ec8d5ac8 (diff) |
Impl Default for ClientHandlers
Signed-off-by: Matthias Beyer <mail@beyermatthias.de>
-rw-r--r-- | src/client/mod.rs | 5 | ||||
-rw-r--r-- | src/client/send.rs | 10 |
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, |