From b5be9502b4d769832a1b31a9e963830247a16ad9 Mon Sep 17 00:00:00 2001
From: Nikolay Kim <fafhrd91@gmail.com>
Date: Tue, 10 Dec 2024 19:57:10 +0500
Subject: [PATCH] Remove Unpin requirements for Arbiter::spawn() (#485)

---
 ntex-rt/CHANGES.md     | 4 ++++
 ntex-rt/Cargo.toml     | 2 +-
 ntex-rt/src/arbiter.rs | 6 +++---
 3 files changed, 8 insertions(+), 4 deletions(-)

diff --git a/ntex-rt/CHANGES.md b/ntex-rt/CHANGES.md
index 608187e5..a1366130 100644
--- a/ntex-rt/CHANGES.md
+++ b/ntex-rt/CHANGES.md
@@ -1,5 +1,9 @@
 # Changes
 
+## [0.4.23] - 2024-12-10
+
+* Remove Unpin requirements for Arbiter::spawn()
+
 ## [0.4.22] - 2024-12-01
 
 * Depend on individual compio packages
diff --git a/ntex-rt/Cargo.toml b/ntex-rt/Cargo.toml
index 70c54719..7632b628 100644
--- a/ntex-rt/Cargo.toml
+++ b/ntex-rt/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "ntex-rt"
-version = "0.4.22"
+version = "0.4.23"
 authors = ["ntex contributors <team@ntex.rs>"]
 description = "ntex runtime"
 keywords = ["network", "framework", "async", "futures"]
diff --git a/ntex-rt/src/arbiter.rs b/ntex-rt/src/arbiter.rs
index f2c5e939..bdf0e100 100644
--- a/ntex-rt/src/arbiter.rs
+++ b/ntex-rt/src/arbiter.rs
@@ -21,7 +21,7 @@ pub(super) static COUNT: AtomicUsize = AtomicUsize::new(0);
 
 pub(super) enum ArbiterCommand {
     Stop,
-    Execute(Box<dyn Future<Output = ()> + Unpin + Send>),
+    Execute(Pin<Box<dyn Future<Output = ()> + Send>>),
     ExecuteFn(Box<dyn FnExec>),
 }
 
@@ -147,11 +147,11 @@ impl Arbiter {
     /// Send a future to the Arbiter's thread, and spawn it.
     pub fn spawn<F>(&self, future: F)
     where
-        F: Future<Output = ()> + Send + Unpin + 'static,
+        F: Future<Output = ()> + Send + 'static,
     {
         let _ = self
             .sender
-            .try_send(ArbiterCommand::Execute(Box::new(future)));
+            .try_send(ArbiterCommand::Execute(Box::pin(future)));
     }
 
     /// Send a function to the Arbiter's thread. This function will be executed asynchronously.