From 5e742c5a0048da0c778a9d64bd339f6b409b3db9 Mon Sep 17 00:00:00 2001 From: slinkydeveloper Date: Mon, 4 Nov 2024 10:14:02 +0100 Subject: [PATCH] No need for the run future to be `Sync` --- src/context/mod.rs | 4 ++-- src/endpoint/context.rs | 14 +++++++------- 2 files changed, 9 insertions(+), 9 deletions(-) diff --git a/src/context/mod.rs b/src/context/mod.rs index 0726c0b..7c99a63 100644 --- a/src/context/mod.rs +++ b/src/context/mod.rs @@ -375,8 +375,8 @@ pub trait ContextSideEffects<'ctx>: private::SealedContext<'ctx> { #[must_use] fn run(&self, run_closure: R) -> impl RunFuture> + 'ctx where - R: RunClosure + Send + Sync + 'ctx, - F: Future> + Send + Sync + 'ctx, + R: RunClosure + Send + 'ctx, + F: Future> + Send + 'ctx, T: Serialize + Deserialize + 'static, { self.inner_context().run(run_closure) diff --git a/src/endpoint/context.rs b/src/endpoint/context.rs index 33de131..536dcb5 100644 --- a/src/endpoint/context.rs +++ b/src/endpoint/context.rs @@ -530,10 +530,10 @@ impl ContextInternal { pub fn run<'a, Run, Fut, Out>( &'a self, run_closure: Run, - ) -> impl crate::context::RunFuture> + Send + Sync + 'a + ) -> impl crate::context::RunFuture> + Send + 'a where - Run: RunClosure + Send + Sync + 'a, - Fut: Future> + Send + Sync + 'a, + Run: RunClosure + Send + 'a, + Fut: Future> + Send + 'a, Out: Serialize + Deserialize + 'static, { let this = Arc::clone(&self.inner); @@ -634,8 +634,8 @@ impl RunFuture { impl crate::context::RunFuture, Error>> for RunFuture where - Run: RunClosure + Send + Sync, - Fut: Future> + Send + Sync, + Run: RunClosure + Send, + Fut: Future> + Send, Out: Serialize + Deserialize, { fn retry_policy(mut self, retry_policy: RunRetryPolicy) -> Self { @@ -657,9 +657,9 @@ where impl Future for RunFuture where - Run: RunClosure + Send + Sync, + Run: RunClosure + Send, Out: Serialize + Deserialize, - Fut: Future> + Send + Sync, + Fut: Future> + Send, { type Output = Result, Error>;