diff --git a/src/proto/h2/server.rs b/src/proto/h2/server.rs index eea52e3e4b..d34802b727 100644 --- a/src/proto/h2/server.rs +++ b/src/proto/h2/server.rs @@ -162,6 +162,7 @@ where S: HttpService, S::Error: Into>, B: HttpBody + 'static, + B::Data: Send, E: ConnStreamExec, { type Output = crate::Result; @@ -206,6 +207,7 @@ impl Serving where T: AsyncRead + AsyncWrite + Unpin, B: HttpBody + 'static, + B::Data: Send, { fn poll_server( &mut self, @@ -364,6 +366,7 @@ impl H2Stream where F: Future, E>>, B: HttpBody, + B::Data: Send + 'static, B::Error: Into>, E: Into>, { @@ -428,6 +431,7 @@ impl Future for H2Stream where F: Future, E>>, B: HttpBody, + B::Data: Send + 'static, B::Error: Into>, E: Into>, { diff --git a/src/server/conn.rs b/src/server/conn.rs index c1a52f1c0d..0e58a60c95 100644 --- a/src/server/conn.rs +++ b/src/server/conn.rs @@ -615,6 +615,7 @@ where S::Error: Into>, I: AsyncRead + AsyncWrite + Unpin, B: HttpBody + 'static, + B::Data: Send, B::Error: Into>, E: ConnStreamExec, { @@ -772,6 +773,7 @@ where S::Error: Into>, I: AsyncRead + AsyncWrite + Unpin + 'static, B: HttpBody + 'static, + B::Data: Send, B::Error: Into>, E: ConnStreamExec, { @@ -978,6 +980,7 @@ where S: HttpService, S::Error: Into>, B: HttpBody + 'static, + B::Data: Send, B::Error: Into>, E: ConnStreamExec, { @@ -1028,6 +1031,7 @@ pub(crate) mod spawn_all { S: HttpService, E: ConnStreamExec, S::ResBody: 'static, + ::Data: Send, ::Error: Into>, { type Future = UpgradeableConnection; @@ -1075,6 +1079,7 @@ pub(crate) mod spawn_all { NE: Into>, S: HttpService, B: HttpBody + 'static, + B::Data: Send, B::Error: Into>, E: ConnStreamExec, W: Watcher, @@ -1141,6 +1146,7 @@ mod upgrades { S::Error: Into>, I: AsyncRead + AsyncWrite + Unpin, B: HttpBody + 'static, + B::Data: Send, B::Error: Into>, E: ConnStreamExec, { @@ -1159,6 +1165,7 @@ mod upgrades { S::Error: Into>, I: AsyncRead + AsyncWrite + Unpin + Send + 'static, B: HttpBody + 'static, + B::Data: Send, B::Error: Into>, E: ConnStreamExec, { diff --git a/src/server/server.rs b/src/server/server.rs index 20c993e8ac..344ab1c508 100644 --- a/src/server/server.rs +++ b/src/server/server.rs @@ -100,6 +100,7 @@ where S: MakeServiceRef, S::Error: Into>, B: HttpBody + Send + Sync + 'static, + B::Data: Send, B::Error: Into>, E: ConnStreamExec<>::Future, B>, E: NewSvcExec, @@ -156,6 +157,7 @@ where S: MakeServiceRef, S::Error: Into>, B: HttpBody + 'static, + B::Data: Send, B::Error: Into>, E: ConnStreamExec<>::Future, B>, E: NewSvcExec, @@ -426,6 +428,7 @@ impl Builder { S: MakeServiceRef, S::Error: Into>, B: HttpBody + 'static, + B::Data: Send, B::Error: Into>, E: NewSvcExec, E: ConnStreamExec<>::Future, B>, diff --git a/src/server/shutdown.rs b/src/server/shutdown.rs index e54ba42104..449b6d81b1 100644 --- a/src/server/shutdown.rs +++ b/src/server/shutdown.rs @@ -51,6 +51,7 @@ where S: MakeServiceRef, S::Error: Into>, B: HttpBody + Send + Sync + 'static, + B::Data: Send, B::Error: Into>, F: Future, E: ConnStreamExec<>::Future, B>, @@ -98,6 +99,7 @@ where S: HttpService, E: ConnStreamExec, S::ResBody: Send + Sync + 'static, + ::Data: Send, ::Error: Into>, { type Future = @@ -114,6 +116,7 @@ where S::Error: Into>, I: AsyncRead + AsyncWrite + Unpin, S::ResBody: HttpBody + Send + 'static, + ::Data: Send, ::Error: Into>, E: ConnStreamExec, {