remove dependant on nightly Rust feature

http-file/CHANGES.md

@@ -1,3 +1,4 @@
 # unreleased 0.2.0
 ## Change
+- project compile on stable Rust channel with MSRV of 1.79
 - update `tokio-uring` to `0.5.0`

http-file/src/lib.rs

@@ -1,7 +1,5 @@
 //! local file serving with http.
 
-#![feature(impl_trait_in_assoc_type)]
-
 pub mod runtime;
 
 mod buf;

http-file/src/runtime.rs

@@ -58,22 +58,26 @@ pub(crate) use tokio_impl::TokioFs;
 
 #[cfg(feature = "tokio")]
 mod tokio_impl {
+    use core::pin::Pin;
+
     use tokio::{
         fs::File,
         io::{AsyncReadExt, AsyncSeekExt},
     };
 
     use super::*;
 
+    type BoxFuture<'a, T> = Pin<Box<dyn Future<Output = T> + Send + 'a>>;
+
     #[derive(Clone)]
     pub struct TokioFs;
 
     impl AsyncFs for TokioFs {
         type File = TokioFile;
-        type OpenFuture = impl Future<Output = io::Result<Self::File>> + Send;
+        type OpenFuture = BoxFuture<'static, io::Result<Self::File>>;
 
         fn open(&self, path: PathBuf) -> Self::OpenFuture {
-            async {
+            Box::pin(async {
                 tokio::task::spawn_blocking(move || {
                     let file = std::fs::File::open(path)?;
                     let meta = file.metadata()?;
@@ -87,7 +91,7 @@ mod tokio_impl {
                 })
                 .await
                 .unwrap()
-            }
+            })
         }
     }
 
@@ -109,25 +113,25 @@ mod tokio_impl {
 
     impl ChunkRead for TokioFile {
         type SeekFuture<'f>
-            = impl Future<Output = io::Result<()>> + Send + 'f
+            = BoxFuture<'f, io::Result<()>>
         where
             Self: 'f;
 
-        type Future = impl Future<Output = io::Result<Option<(Self, BytesMut, usize)>>> + Send;
+        type Future = BoxFuture<'static, io::Result<Option<(Self, BytesMut, usize)>>>;
 
         fn seek(&mut self, pos: SeekFrom) -> Self::SeekFuture<'_> {
-            async move { self.file.seek(pos).await.map(|_| ()) }
+            Box::pin(async move { self.file.seek(pos).await.map(|_| ()) })
         }
 
         fn next(mut self, mut buf: BytesMut) -> Self::Future {
-            async {
+            Box::pin(async {
                 let n = self.file.read_buf(&mut buf).await?;
                 if n == 0 {
                     Ok(None)
                 } else {
                     Ok(Some((self, buf, n)))
                 }
-            }
+            })
         }
     }
 }
@@ -137,19 +141,26 @@ pub(crate) use tokio_uring_impl::TokioUringFs;
 
 #[cfg(feature = "tokio-uring")]
 mod tokio_uring_impl {
+    use core::{
+        future::{ready, Ready},
+        pin::Pin,
+    };
+
     use tokio_uring::fs::File;
 
     use super::*;
 
+    type BoxFuture<'f, T> = Pin<Box<dyn Future<Output = T> + 'f>>;
+
     #[derive(Clone)]
     pub struct TokioUringFs;
 
     impl AsyncFs for TokioUringFs {
         type File = TokioUringFile;
-        type OpenFuture = impl Future<Output = io::Result<Self::File>>;
+        type OpenFuture = BoxFuture<'static, io::Result<Self::File>>;
 
         fn open(&self, path: PathBuf) -> Self::OpenFuture {
-            async {
+            Box::pin(async {
                 let file = File::open(path).await?;
 
                 // SAFETY: fd is borrowed and lives longer than the unsafe block
@@ -173,7 +184,7 @@ mod tokio_uring_impl {
                     modified_time,
                     len,
                 })
-            }
+            })
         }
     }
 
@@ -196,22 +207,22 @@ mod tokio_uring_impl {
 
     impl ChunkRead for TokioUringFile {
         type SeekFuture<'f>
-            = impl Future<Output = io::Result<()>> + 'f
+            = Ready<io::Result<()>>
         where
             Self: 'f;
 
-        type Future = impl Future<Output = io::Result<Option<(Self, BytesMut, usize)>>>;
+        type Future = BoxFuture<'static, io::Result<Option<(Self, BytesMut, usize)>>>;
 
         fn seek(&mut self, pos: SeekFrom) -> Self::SeekFuture<'_> {
             let SeekFrom::Start(pos) = pos else {
                 unreachable!("ChunkRead::seek only accept pos as SeekFrom::Start variant")
             };
             self.pos += pos;
-            async { Ok(()) }
+            ready(Ok(()))
         }
 
         fn next(mut self, buf: BytesMut) -> Self::Future {
-            async {
+            Box::pin(async {
                 let (res, buf) = self.file.read_at(buf, self.pos).await;
                 let n = res?;
                 if n == 0 {
@@ -220,7 +231,7 @@ mod tokio_uring_impl {
                     self.pos += n as u64;
                     Ok(Some((self, buf, n)))
                 }
-            }
+            })
         }
     }
 }

web/Cargo.toml

@@ -55,7 +55,7 @@ file = ["file-raw", "http-file/default"]
 # static file serving with io-uring 
 file-io-uring = ["io-uring", "file", "http-file/tokio-uring"]
 # static file serving without default file system
-file-raw = ["http-file", "nightly"]
+file-raw = ["http-file"]
 
 # rate-limit middleware
 rate-limit = ["http-rate"]