tokio-fs bump version

tokio-fs/Cargo.toml

@@ -15,9 +15,8 @@ maintenance = { status = "actively-developed" }
 # See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
 
 [dependencies]
-dmds = "0.2"
-async-trait = "0.1"
-tokio = { version = "1.34", features = ["fs", "io-util", "time", "rt"] }
+dmds = "0.4"
+tokio = { version = "1.37", features = ["fs", "io-util", "time", "rt"] }
 futures = { version = "0.3", features = ["executor"] }
 dashmap = "5.5"
-bytes = "1.5"
+bytes = "1.6"

tokio-fs/src/lib.rs

@@ -1,11 +1,14 @@
+//! Tokio async filesystem implementation of `dmds` [`IoHandle`].
+
+#![warn(missing_docs)]
+
 use std::{
     path::{Path, PathBuf},
     pin::Pin,
     sync::Arc,
     time::Duration,
 };
 
-use async_trait::async_trait;
 use bytes::{BufMut, BytesMut};
 use dashmap::DashSet;
 use dmds::IoHandle;
@@ -29,7 +32,6 @@ pub struct FsHandle {
     invalid_chunks: DashSet<Box<[usize]>>,
 }
 
-#[async_trait]
 impl IoHandle for FsHandle {
     type Read<'a> = FsReader<'a> where Self: 'a;
 
@@ -210,7 +212,7 @@ pub async fn daemon<T, const DIMS: usize>(
 {
     const LEAST_WRITES: usize = 1;
 
-    let _ = ShutdownHandle::new(world.clone());
+    let _handle = ShutdownHandle::new(world.clone());
 
     loop {
         tokio::time::sleep(write_interval).await;