fix: shutdown_hook not send

cloudwego · Oct 31, 2023 · 807a58c · 807a58c
1 parent 25885a7
commit 807a58c
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/volo-thrift/Cargo.toml b/volo-thrift/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "volo-thrift"
-version = "0.8.0"
+version = "0.8.1"
 edition.workspace = true
 homepage.workspace = true
 repository.workspace = true

diff --git a/volo-thrift/src/server.rs b/volo-thrift/src/server.rs
@@ -43,7 +43,7 @@ pub struct Server<S, L, Req, MkC, SP> {
     #[cfg(feature = "multiplex")]
     multiplex: bool,
     span_provider: SP,
-    shutdown_hooks: Vec<Box<dyn FnOnce() -> BoxFuture<'static, ()>>>,
+    shutdown_hooks: Vec<Box<dyn FnOnce() -> BoxFuture<'static, ()> + Send>>,
     _marker: PhantomData<Req>,
 }
 
@@ -81,7 +81,7 @@ impl<S, L, Req, MkC, SP> Server<S, L, Req, MkC, SP> {
     /// in reverse order of registration.
     pub fn register_shutdown_hook(
         mut self,
-        hook: impl FnOnce() -> BoxFuture<'static, ()> + 'static,
+        hook: impl FnOnce() -> BoxFuture<'static, ()> + 'static + Send,
     ) -> Self {
         self.shutdown_hooks.push(Box::new(hook));
         self