fmt

Author: orthur2

mea/src/rwlock/mapped_write_guard.rs

@@ -293,17 +293,19 @@ impl<'a, T: ?Sized> MappedRwLockWriteGuard<'a, T> {
     /// This method changes the lock from exclusive mode to shared mode atomically,
     /// preventing other writers from acquiring the lock in between.
     ///
-    /// The returned `MappedRwLockReadGuard` preserves the original mapping to the specific 
+    /// The returned `MappedRwLockReadGuard` preserves the original mapping to the specific
     /// component of the data.
     ///
     /// # Examples
     ///
     /// ```
     /// # #[tokio::main]
     /// # async fn main() {
-    /// use mea::rwlock::{RwLock, RwLockWriteGuard};
     /// use std::sync::Arc;
     ///
+    /// use mea::rwlock::RwLock;
+    /// use mea::rwlock::RwLockWriteGuard;
+    ///
     /// #[derive(Debug)]
     /// struct Counter {
     ///     value: i32,

mea/src/rwlock/owned_mapped_write_guard.rs

@@ -329,7 +329,9 @@ impl<T: ?Sized, U: ?Sized> OwnedMappedRwLockWriteGuard<T, U> {
     /// # #[tokio::main]
     /// # async fn main() {
     /// use std::sync::Arc;
-    /// use mea::rwlock::{RwLock, OwnedRwLockWriteGuard};
+    ///
+    /// use mea::rwlock::OwnedRwLockWriteGuard;
+    /// use mea::rwlock::RwLock;
     ///
     /// #[derive(Debug)]
     /// struct Database {
@@ -343,7 +345,8 @@ impl<T: ?Sized, U: ?Sized> OwnedMappedRwLockWriteGuard<T, U> {
     /// }));
     ///
     /// let write_guard = db.clone().write_owned().await;
-    /// let mut count_write_guard = OwnedRwLockWriteGuard::map(write_guard, |db| &mut db.connection_count);
+    /// let mut count_write_guard =
+    ///     OwnedRwLockWriteGuard::map(write_guard, |db| &mut db.connection_count);
     /// *count_write_guard = 5;
     ///
     /// let db_clone = db.clone();

mea/src/rwlock/owned_write_guard.rs

@@ -278,17 +278,18 @@ impl<T: ?Sized> OwnedRwLockWriteGuard<T> {
     /// This method changes the lock from exclusive mode to shared mode atomically,
     /// preventing other writers from acquiring the lock in between.
     ///
-    /// The returned `OwnedRwLockReadGuard` has a `'static` lifetime, as it keeps 
+    /// The returned `OwnedRwLockReadGuard` has a `'static` lifetime, as it keeps
     /// the `RwLock` alive by holding an `Arc`.
     ///
     /// # Examples
     ///
     /// ```
     /// # #[tokio::main]
     /// # async fn main() {
-    /// use mea::rwlock::RwLock;
     /// use std::sync::Arc;
     ///
+    /// use mea::rwlock::RwLock;
+    ///
     /// let lock = Arc::new(RwLock::new(1));
     ///
     /// let mut write_guard = lock.clone().write_owned().await;

mea/src/rwlock/read_guard.rs

@@ -146,7 +146,9 @@ impl<'a, T: ?Sized> RwLockReadGuard<'a, T> {
     /// acquiring a new semaphore permit, as it relies on the permit
     /// already held by the `RwLockWriteGuard`.
     pub(super) fn from_write_downgrade(write_guard: ManuallyDrop<RwLockWriteGuard<'a, T>>) -> Self {
-        Self { lock: write_guard.lock }
+        Self {
+            lock: write_guard.lock,
+        }
     }
     /// Makes a new [`MappedRwLockReadGuard`] for a component of the locked data.
     ///

mea/src/rwlock/test.rs

@@ -815,7 +815,11 @@ async fn test_downgrade_allows_concurrent_readers() {
 
     for handle in reader_handles {
         let (reader_id, value) = handle.await.unwrap();
-        assert_eq!(value, 42, "Reader {} should see the written value", reader_id);
+        assert_eq!(
+            value, 42,
+            "Reader {} should see the written value",
+            reader_id
+        );
     }
 }
 #[tokio::test]
@@ -1034,7 +1038,11 @@ async fn test_owned_write_guard_downgrade_no_memory_leak() {
 
     drop(rwlock);
 
-    assert_eq!(weak_ref.strong_count(), 0, "Memory leak detected in OwnedRwLockWriteGuard downgrade!");
+    assert_eq!(
+        weak_ref.strong_count(),
+        0,
+        "Memory leak detected in OwnedRwLockWriteGuard downgrade!"
+    );
 }
 
 #[tokio::test]
@@ -1055,5 +1063,9 @@ async fn test_owned_mapped_write_guard_downgrade_no_memory_leak() {
 
     drop(rwlock);
 
-    assert_eq!(weak_ref.strong_count(), 0, "Memory leak detected in OwnedMappedRwLockWriteGuard downgrade!");
+    assert_eq!(
+        weak_ref.strong_count(),
+        0,
+        "Memory leak detected in OwnedMappedRwLockWriteGuard downgrade!"
+    );
 }

mea/src/rwlock/write_guard.rs

@@ -258,9 +258,10 @@ impl<'a, T: ?Sized> RwLockWriteGuard<'a, T> {
     /// ```
     /// # #[tokio::main]
     /// # async fn main() {
-    /// use mea::rwlock::RwLock;
     /// use std::sync::Arc;
     ///
+    /// use mea::rwlock::RwLock;
+    ///
     /// let lock = Arc::new(RwLock::new(1));
     ///
     /// let mut write_guard = lock.write().await;
@@ -300,4 +301,4 @@ impl<'a, T: ?Sized> RwLockWriteGuard<'a, T> {
 
         RwLockReadGuard::from_write_downgrade(guard)
     }
-}
+}