wip

README.md

@@ -9,7 +9,7 @@
 [![Version](https://img.shields.io/badge/rustc-1.75+-lightgray.svg)](https://blog.rust-lang.org/2023/12/28/Rust-1.75.0.html) 
 ![License](https://img.shields.io/crates/l/ntex.svg) 
 [![codecov](https://codecov.io/gh/ntex-rs/ntex/branch/master/graph/badge.svg)](https://codecov.io/gh/ntex-rs/ntex) 
-[![Chat on Discord](https://img.shields.io/discord/919288597826387979?label=chat&logo=discord)](https://discord.gg/zBNyhVRz) 
+[![Chat on Discord](https://img.shields.io/discord/919288597826387979?label=chat&logo=discord)](https://discord.com/channels/919288597826387979/919288597826387982) 
  
   </p>
 </div>

ntex-service/src/boxed.rs

@@ -54,6 +54,8 @@ trait ServiceObj<Req> {
         waiters: &'a WaitersRef,
     ) -> BoxFuture<'a, (), Self::Error>;
 
+    fn not_ready(&self) -> BoxFuture<'_, (), Self::Error>;
+
     fn call<'a>(
         &'a self,
         req: Req,
@@ -81,6 +83,11 @@ where
         Box::pin(async move { ServiceCtx::<'a, S>::new(idx, waiters).ready(self).await })
     }
 
+    #[inline]
+    fn not_ready(&self) -> BoxFuture<'_, (), Self::Error> {
+        Box::pin(crate::Service::not_ready(self))
+    }
+
     #[inline]
     fn shutdown<'a>(&'a self) -> Pin<Box<dyn Future<Output = ()> + 'a>> {
         Box::pin(crate::Service::shutdown(self))
@@ -151,6 +158,11 @@ where
         self.0.ready(idx, waiters).await
     }
 
+    #[inline]
+    async fn not_ready(&self) -> Result<(), Self::Error> {
+        self.0.not_ready().await
+    }
+
     #[inline]
     async fn shutdown(&self) {
         self.0.shutdown().await

ntex-service/src/ctx.rs

@@ -168,16 +168,16 @@ impl<'a, S> ServiceCtx<'a, S> {
     }
 }
 
-impl<'a, S> Copy for ServiceCtx<'a, S> {}
+impl<S> Copy for ServiceCtx<'_, S> {}
 
-impl<'a, S> Clone for ServiceCtx<'a, S> {
+impl<S> Clone for ServiceCtx<'_, S> {
     #[inline]
     fn clone(&self) -> Self {
         *self
     }
 }
 
-impl<'a, S> fmt::Debug for ServiceCtx<'a, S> {
+impl<S> fmt::Debug for ServiceCtx<'_, S> {
     fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
         f.debug_struct("ServiceCtx")
             .field("idx", &self.idx)
@@ -192,7 +192,7 @@ struct ReadyCall<'a, S: ?Sized, F: Future> {
     ctx: ServiceCtx<'a, S>,
 }
 
-impl<'a, S: ?Sized, F: Future> Drop for ReadyCall<'a, S, F> {
+impl<S: ?Sized, F: Future> Drop for ReadyCall<'_, S, F> {
     fn drop(&mut self) {
         if !self.completed && self.ctx.waiters.cur.get() == self.ctx.idx {
             self.ctx.waiters.notify();
@@ -200,9 +200,9 @@ impl<'a, S: ?Sized, F: Future> Drop for ReadyCall<'a, S, F> {
     }
 }
 
-impl<'a, S: ?Sized, F: Future> Unpin for ReadyCall<'a, S, F> {}
+impl<S: ?Sized, F: Future> Unpin for ReadyCall<'_, S, F> {}
 
-impl<'a, S: ?Sized, F: Future> Future for ReadyCall<'a, S, F> {
+impl<S: ?Sized, F: Future> Future for ReadyCall<'_, S, F> {
     type Output = F::Output;
 
     fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> {

ntex-service/src/lib.rs

@@ -252,6 +252,11 @@ where
         ctx.ready(&**self).await
     }
 
+    #[inline]
+    async fn not_ready(&self) -> Result<(), S::Error> {
+        (**self).not_ready().await
+    }
+
     #[inline]
     async fn shutdown(&self) {
         (**self).shutdown().await
@@ -279,6 +284,11 @@ where
         ctx.ready(&**self).await
     }
 
+    #[inline]
+    async fn not_ready(&self) -> Result<(), S::Error> {
+        (**self).not_ready().await
+    }
+
     #[inline]
     async fn shutdown(&self) {
         (**self).shutdown().await

ntex-service/src/macros.rs

@@ -11,6 +11,14 @@ macro_rules! forward_ready {
                 .await
                 .map_err(::core::convert::Into::into)
         }
+
+        #[inline]
+        async fn not_ready(&self) -> Result<(), Self::Error> {
+            self.$field
+                .not_ready()
+                .await
+                .map_err(::core::convert::Into::into)
+        }
     };
     ($field:ident, $err:expr) => {
         #[inline]
@@ -20,6 +28,11 @@ macro_rules! forward_ready {
         ) -> Result<(), Self::Error> {
             ctx.ready(&self.$field).await.map_err($err)
         }
+
+        #[inline]
+        async fn not_ready(&self) -> Result<(), Self::Error> {
+            self.$field.not_ready().await.map_err($err)
+        }
     };
 }