fix(dir-structure): fix lint

Author: dnbln

src/dev/dir-structure/src/atomic_dir.rs

@@ -285,9 +285,12 @@ where
                 match fut.as_mut().poll(cx) {
                     Poll::Ready(result) => {
                         *self = Self::Done;
-                        return Poll::Ready(result);
+                        Poll::Ready(result)
+                    }
+                    Poll::Pending => {
+                        self.as_mut().project_replace(Self::PersistingTempDir(fut));
+                        Poll::Pending
                     }
-                    Poll::Pending => return Poll::Pending,
                 }
             }
             AtomicDirWriteToAsyncRefFutureProj::DeletingTempDir(mut fut, error) => {

src/dev/dir-structure/src/vfs/fs_vfs.rs

@@ -136,7 +136,12 @@ mod imp {
 pub(crate) mod atomic_dir_imp {
     //! The [`VfsSupportsTemporaryDirectories`] implementation for the [`FsVfs`] file system.
 
+    use std::env;
+    use std::fs;
+    use std::mem;
+    use std::process;
     use std::sync::atomic::AtomicU64;
+    use std::sync::atomic::Ordering;
 
     use super::*;
     use crate::atomic_dir::TempDirApi;
@@ -158,23 +163,23 @@ pub(crate) mod atomic_dir_imp {
             path: &<Self::Vfs as VfsCore>::Path,
         ) -> VfsResult<(), Self::Vfs> {
             vfs.create_parent_dir(path)?;
-            std::fs::rename(&self.0, path).wrap_io_error_with(path)?;
+            fs::rename(&self.0, path).wrap_io_error_with(path)?;
             // do not run the Drop impl, as we already moved the directory
-            std::mem::forget(self);
+            mem::forget(self);
             Ok(())
         }
 
         fn delete(self, vfs: Pin<&'vfs Self::Vfs>) -> VfsResult<(), Self::Vfs> {
             vfs.remove_dir_all(&self.0)?;
             // do not run the Drop impl, as we already deleted the directory
-            std::mem::forget(self);
+            mem::forget(self);
             Ok(())
         }
     }
 
     impl Drop for TempDir {
         fn drop(&mut self) {
-            let _ = std::fs::remove_dir_all(&self.0);
+            let _ = fs::remove_dir_all(&self.0);
         }
     }
 
@@ -202,10 +207,10 @@ pub(crate) mod atomic_dir_imp {
     }
 
     pub fn make_new_temp_dir_path() -> PathBuf {
-        std::env::temp_dir().join(format!(
+        env::temp_dir().join(format!(
             "__rust_dir_structure_temp_{}_{}",
-            std::process::id(),
-            FS_TEMP_DIR_ID.fetch_add(1, std::sync::atomic::Ordering::SeqCst)
+            process::id(),
+            FS_TEMP_DIR_ID.fetch_add(1, Ordering::SeqCst)
         ))
     }
 }

src/dev/dir-structure/src/vfs/tokio_fs_vfs.rs

@@ -520,6 +520,8 @@ mod imp {
 mod atomic_dir_imp {
     //! The [`VfsSupportsTemporaryDirectoriesAsync`] implementation for the [`TokioFsVfs`] file system.
 
+    use tokio::fs;
+
     use super::*;
     use crate::atomic_dir::TempDirApiAsync;
     use crate::atomic_dir::VfsSupportsTemporaryDirectoriesAsync;
@@ -549,7 +551,7 @@ mod atomic_dir_imp {
         ) -> Self::FuturePersistAt {
             Box::pin(async move {
                 vfs.create_parent_dir(path.clone()).await?;
-                tokio::fs::rename(&self.0, &path)
+                fs::rename(&self.0, &path)
                     .await
                     .map_err(|e| Error::Io(path.clone(), e))?;
                 Ok(())