No runtime compatibility (#409)

ntex-rt/CHANGES.md

@@ -1,5 +1,9 @@
 # Changes
 
+## [0.4.15] - 2024-08-30
+
+* No runtime compatibility
+
 ## [0.4.14] - 2024-08-29
 
 * Add `compio` runtime support

ntex-rt/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "ntex-rt"
-version = "0.4.14"
+version = "0.4.15"
 authors = ["ntex contributors <team@ntex.rs>"]
 description = "ntex runtime"
 keywords = ["network", "framework", "async", "futures"]

ntex-rt/src/lib.rs

@@ -214,6 +214,16 @@ mod compio {
         fut: Option<comp_io::runtime::JoinHandle<T>>,
     }
 
+    impl<T> JoinHandle<T> {
+        pub fn is_finished(&self) -> bool {
+            if let Some(hnd) = &self.fut {
+                hnd.is_finished()
+            } else {
+                true
+            }
+        }
+    }
+
     impl<T> Drop for JoinHandle<T> {
         fn drop(&mut self) {
             self.fut.take().unwrap().detach();
@@ -473,39 +483,58 @@ pub use self::glommio::*;
 ))]
 pub use self::compio::*;
 
-/// Runs the provided future, blocking the current thread until the future
-/// completes.
+#[allow(dead_code)]
 #[cfg(all(
     not(feature = "tokio"),
     not(feature = "async-std"),
     not(feature = "compio"),
     not(feature = "glommio")
 ))]
-pub fn block_on<F: std::future::Future<Output = ()>>(_: F) {
-    panic!("async runtime is not configured");
-}
+mod no_rt {
+    use std::task::{Context, Poll};
+    use std::{fmt, future::Future, marker::PhantomData, pin::Pin};
 
-#[cfg(all(
-    not(feature = "tokio"),
-    not(feature = "async-std"),
-    not(feature = "compio"),
-    not(feature = "glommio")
-))]
-pub fn spawn<F>(_: F) -> std::pin::Pin<Box<dyn std::future::Future<Output = F::Output>>>
-where
-    F: std::future::Future + 'static,
-{
-    unimplemented!()
-}
+    /// Runs the provided future, blocking the current thread until the future
+    /// completes.
+    pub fn block_on<F: Future<Output = ()>>(_: F) {
+        panic!("async runtime is not configured");
+    }
 
-#[cfg(all(
-    not(feature = "tokio"),
-    not(feature = "async-std"),
-    not(feature = "compio"),
-    not(feature = "glommio")
-))]
-mod spawn_blocking_stub {
-    use std::fmt;
+    pub fn spawn<F>(_: F) -> JoinHandle<F::Output>
+    where
+        F: Future + 'static,
+    {
+        unimplemented!()
+    }
+
+    pub fn spawn_blocking<F, T>(_: F) -> JoinHandle<T>
+    where
+        F: FnOnce() -> T + Send + Sync + 'static,
+        T: Send + 'static,
+    {
+        unimplemented!()
+    }
+
+    /// Blocking operation completion future. It resolves with results
+    /// of blocking function execution.
+    #[allow(clippy::type_complexity)]
+    pub struct JoinHandle<T> {
+        t: PhantomData<T>,
+    }
+
+    impl<T> JoinHandle<T> {
+        pub fn is_finished(&self) -> bool {
+            true
+        }
+    }
+
+    impl<T> Future for JoinHandle<T> {
+        type Output = Result<T, JoinError>;
+
+        fn poll(self: Pin<&mut Self>, _: &mut Context<'_>) -> Poll<Self::Output> {
+            todo!()
+        }
+    }
 
     #[derive(Debug, Copy, Clone)]
     pub struct JoinError;
@@ -517,21 +546,12 @@ mod spawn_blocking_stub {
     }
 
     impl std::error::Error for JoinError {}
-
-    pub fn spawn_blocking<F, T>(
-        _: F,
-    ) -> std::pin::Pin<Box<dyn std::future::Future<Output = Result<T, JoinError>>>>
-    where
-        F: FnOnce() -> T + Send + 'static,
-        T: Send + 'static,
-    {
-        unimplemented!()
-    }
 }
+
 #[cfg(all(
     not(feature = "tokio"),
     not(feature = "async-std"),
     not(feature = "compio"),
     not(feature = "glommio")
 ))]
-pub use self::spawn_blocking_stub::*;
+pub use self::no_rt::*;