[ISSUE #1022]⚡️Add Default trait for RocketMQTokioRwLock and RocketMQ…

…TokioMutex (#1023)
mxsm · Sep 30, 2024 · 3dfebe6 · 3dfebe6
1 parent 9a55483
commit 3dfebe6
Showing 1 changed file with 18 additions and 0 deletions.
diff --git a/rocketmq/src/rocketmq_tokio_lock.rs b/rocketmq/src/rocketmq_tokio_lock.rs
@@ -20,6 +20,15 @@ pub struct RocketMQTokioRwLock<T: ?Sized> {
     lock: tokio::sync::RwLock<T>,
 }
 
+impl<T> Default for RocketMQTokioRwLock<T>
+where
+    T: Default,
+{
+    fn default() -> Self {
+        Self::new(T::default())
+    }
+}
+
 impl<T: ?Sized> RocketMQTokioRwLock<T> {
     /// Creates a new `RocketMQTokioRwLock` instance containing the given data.
     ///
@@ -206,6 +215,15 @@ impl<T: ?Sized> RocketMQTokioMutex<T> {
     }
 }
 
+impl<T> Default for RocketMQTokioMutex<T>
+where
+    T: Default,
+{
+    fn default() -> Self {
+        Self::new(T::default())
+    }
+}
+
 #[cfg(test)]
 mod tests {
     use std::sync::Arc;