mirrors/ntex
1
0
Fork 0
mirror of https://github.com/ntex-rs/ntex.git synced 2025-04-03 21:07:39 +03:00
Code Issues Projects Releases Packages Wiki Activity

Remove Unpin requirements for Arbiter::spawn() (#485)

Browse source
This commit is contained in:
Nikolay Kim 2024-12-10 19:57:10 +05:00 • committed by GitHub
parent 22ee7f2af2
commit b5be9502b4
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
3 changed files with 8 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

4
ntex-rt/CHANGES.md
View file

@ -1,5 +1,9 @@
# Changes # Changes
## [0.4.23] - 2024-12-10
* Remove Unpin requirements for Arbiter::spawn()
## [0.4.22] - 2024-12-01 ## [0.4.22] - 2024-12-01
* Depend on individual compio packages * Depend on individual compio packages

2
ntex-rt/Cargo.toml
View file

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

6
ntex-rt/src/arbiter.rs
View file

@ -21,7 +21,7 @@ pub(super) static COUNT: AtomicUsize = AtomicUsize::new(0);
pub(super) enum ArbiterCommand { pub(super) enum ArbiterCommand {
Stop, Stop,
Execute(Box<dyn Future<Output = ()> + Unpin + Send>), Execute(Pin<Box<dyn Future<Output = ()> + Send>>),
ExecuteFn(Box<dyn FnExec>), ExecuteFn(Box<dyn FnExec>),
} }
@ -147,11 +147,11 @@ impl Arbiter {
/// Send a future to the Arbiter's thread, and spawn it. /// Send a future to the Arbiter's thread, and spawn it.
pub fn spawn<F>(&self, future: F) pub fn spawn<F>(&self, future: F)
where where
F: Future<Output = ()> + Send + Unpin + 'static, F: Future<Output = ()> + Send + 'static,
{ {
let _ = self let _ = self
.sender .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. /// Send a function to the Arbiter's thread. This function will be executed asynchronously.