diff --git a/src/client/conn/http1.rs b/src/client/conn/http1.rs
index ec64543c23..0e592165a1 100644
--- a/src/client/conn/http1.rs
+++ b/src/client/conn/http1.rs
@@ -17,7 +17,7 @@ use crate::body::{Body, Incoming as IncomingBody};
 use crate::proto;
 
 type Dispatcher<T, B> =
-    proto::dispatch::Dispatcher<proto::dispatch::Client<B>, B, T, proto::h1::ClientTransaction>;
+    proto::dispatch::Dispatcher<'static, proto::dispatch::Client<B>, B, T, proto::h1::ClientTransaction>;
 
 /// The sender side of an established connection.
 pub struct SendRequest<B> {
diff --git a/src/proto/h1/dispatch.rs b/src/proto/h1/dispatch.rs
index 3a9b536ea4..8700069bd9 100644
--- a/src/proto/h1/dispatch.rs
+++ b/src/proto/h1/dispatch.rs
@@ -19,12 +19,13 @@ use crate::common::task;
 use crate::proto::{BodyLength, Conn, Dispatched, MessageHead, RequestHead};
 use crate::upgrade::OnUpgrade;
 
-pub(crate) struct Dispatcher<D, Bs: Body, I, T> {
+pub(crate) struct Dispatcher<'body, D, Bs: Body + 'body, I, T> {
     conn: Conn<I, Bs::Data, T>,
     dispatch: D,
     body_tx: SenderDropGuard,
     body_rx: Pin<Box<Option<Bs>>>,
     is_closing: bool,
+    _a: std::marker::PhantomData<&'body ()>
 }
 
 pub(crate) trait Dispatch {
@@ -64,7 +65,7 @@ cfg_client! {
     type ClientRx<B> = crate::client::dispatch::Receiver<Request<B>, http::Response<IncomingBody>>;
 }
 
-impl<D, Bs, I, T> Dispatcher<D, Bs, I, T>
+impl<'body, D, Bs, I, T> Dispatcher<'body, D, Bs, I, T>
 where
     D: Dispatch<
             PollItem = MessageHead<T::Outgoing>,
@@ -74,7 +75,7 @@ where
     D::PollError: Into<Box<dyn StdError + Send + Sync>>,
     I: Read + Write + Unpin,
     T: Http1Transaction + Unpin,
-    Bs: Body + 'static,
+    Bs: Body + 'body,
     Bs::Error: Into<Box<dyn StdError + Send + Sync>>,
 {
     pub(crate) fn new(dispatch: D, conn: Conn<I, Bs::Data, T>) -> Self {
@@ -84,6 +85,7 @@ where
             body_tx: SenderDropGuard::none(),
             body_rx: Box::pin(None),
             is_closing: false,
+            _a: Default::default()
         }
     }
 
@@ -476,7 +478,7 @@ where
     }
 }
 
-impl<D, Bs, I, T> Future for Dispatcher<D, Bs, I, T>
+impl<'body, D, Bs, I, T> Future for Dispatcher<'body, D, Bs, I, T>
 where
     D: Dispatch<
             PollItem = MessageHead<T::Outgoing>,
@@ -486,7 +488,7 @@ where
     D::PollError: Into<Box<dyn StdError + Send + Sync>>,
     I: Read + Write + Unpin,
     T: Http1Transaction + Unpin,
-    Bs: Body + 'static,
+    Bs: Body + 'body,
     Bs::Error: Into<Box<dyn StdError + Send + Sync>>,
 {
     type Output = crate::Result<Dispatched>;
diff --git a/src/proto/h2/server.rs b/src/proto/h2/server.rs
index 6645734f31..c186740bcb 100644
--- a/src/proto/h2/server.rs
+++ b/src/proto/h2/server.rs
@@ -80,7 +80,7 @@ impl Default for Config {
 }
 
 pin_project! {
-    pub(crate) struct Server<T, S, B, E>
+    pub(crate) struct Server<'body, T, S, B, E>
     where
         S: HttpService<IncomingBody>,
         B: Body,
@@ -90,7 +90,8 @@ pin_project! {
         service: S,
         state: State<T, B>,
         date_header: bool,
-        close_pending: bool
+        close_pending: bool,
+        _v: std::marker::PhantomData<&'body ()>
     }
 }
 
@@ -117,12 +118,12 @@ where
     date_header: bool,
 }
 
-impl<T, S, B, E> Server<T, S, B, E>
+impl<'body, T, S, B, E> Server<'body, T, S, B, E>
 where
     T: Read + Write + Unpin,
     S: HttpService<IncomingBody, ResBody = B>,
     S::Error: Into<Box<dyn StdError + Send + Sync>>,
-    B: Body + 'static,
+    B: Body + 'body,
     E: Http2ServerConnExec<S::Future, B>,
 {
     pub(crate) fn new(
@@ -131,7 +132,7 @@ where
         config: &Config,
         exec: E,
         timer: Time,
-    ) -> Server<T, S, B, E> {
+    ) -> Server<'body, T, S, B, E> {
         let mut builder = h2::server::Builder::default();
         builder
             .initial_window_size(config.initial_stream_window_size)
@@ -179,6 +180,7 @@ where
             service,
             date_header: config.date_header,
             close_pending: false,
+            _v: Default::default()
         }
     }
 
@@ -197,12 +199,12 @@ where
     }
 }
 
-impl<T, S, B, E> Future for Server<T, S, B, E>
+impl<'body, T, S, B, E> Future for Server<'body, T, S, B, E>
 where
     T: Read + Write + Unpin,
     S: HttpService<IncomingBody, ResBody = B>,
     S::Error: Into<Box<dyn StdError + Send + Sync>>,
-    B: Body + 'static,
+    B: Body + 'body,
     E: Http2ServerConnExec<S::Future, B>,
 {
     type Output = crate::Result<Dispatched>;
@@ -246,7 +248,7 @@ where
 impl<T, B> Serving<T, B>
 where
     T: Read + Write + Unpin,
-    B: Body + 'static,
+    B: Body,
 {
     fn poll_server<S, E>(
         &mut self,
diff --git a/src/server/conn/http1.rs b/src/server/conn/http1.rs
index 7bd3d72e2f..892bafca95 100644
--- a/src/server/conn/http1.rs
+++ b/src/server/conn/http1.rs
@@ -22,7 +22,8 @@ use crate::{
     rt::Timer,
 };
 
-type Http1Dispatcher<T, B, S> = proto::h1::Dispatcher<
+type Http1Dispatcher<'body, T, B, S> = proto::h1::Dispatcher<
+    'body,
     proto::h1::dispatch::Server<S, IncomingBody>,
     B,
     T,
@@ -37,11 +38,11 @@ pin_project_lite::pin_project! {
     /// To drive HTTP on this connection this future **must be polled**, typically with
     /// `.await`. If it isn't polled, no progress will be made on this connection.
     #[must_use = "futures do nothing unless polled"]
-    pub struct Connection<T, S>
+    pub struct Connection<'body, T, S>
     where
         S: HttpService<IncomingBody>,
     {
-        conn: Http1Dispatcher<T, S::ResBody, S>,
+        conn: Http1Dispatcher<'body, T, S::ResBody, S>,
     }
 }
 
@@ -108,7 +109,7 @@ pub struct Parts<T, S> {
 
 // ===== impl Connection =====
 
-impl<I, S> fmt::Debug for Connection<I, S>
+impl<'body, I, S> fmt::Debug for Connection<'body, I, S>
 where
     S: HttpService<IncomingBody>,
 {
@@ -117,12 +118,12 @@ where
     }
 }
 
-impl<I, B, S> Connection<I, S>
+impl<'body, I, B, S> Connection<'body, I, S>
 where
-    S: HttpService<IncomingBody, ResBody = B>,
+    S: HttpService<IncomingBody, ResBody = B> + 'body,
     S::Error: Into<Box<dyn StdError + Send + Sync>>,
-    I: Read + Write + Unpin,
-    B: Body + 'static,
+    I: Read + Write + Unpin + 'body,
+    B: Body + 'body,
     B::Error: Into<Box<dyn StdError + Send + Sync>>,
 {
     /// Start a graceful shutdown process for this connection.
@@ -178,7 +179,7 @@ where
     /// # Error
     ///
     /// This errors if the underlying connection protocol is not HTTP/1.
-    pub fn without_shutdown(self) -> impl Future<Output = crate::Result<Parts<I, S>>> {
+    pub fn without_shutdown(self) -> impl Future<Output = crate::Result<Parts<I, S>>> + 'body {
         let mut zelf = Some(self);
         crate::common::future::poll_fn(move |cx| {
             ready!(zelf
@@ -196,7 +197,7 @@ where
     /// Enable this connection to support higher-level HTTP upgrades.
     ///
     /// See [the `upgrade` module](crate::upgrade) for more.
-    pub fn with_upgrades(self) -> UpgradeableConnection<I, S>
+    pub fn with_upgrades(self) -> UpgradeableConnection<'body, I, S>
     where
         I: Send,
     {
@@ -204,12 +205,12 @@ where
     }
 }
 
-impl<I, B, S> Future for Connection<I, S>
+impl<'body, I, B, S> Future for Connection<'body, I, S>
 where
     S: HttpService<IncomingBody, ResBody = B>,
     S::Error: Into<Box<dyn StdError + Send + Sync>>,
     I: Read + Write + Unpin,
-    B: Body + 'static,
+    B: Body + 'body,
     B::Error: Into<Box<dyn StdError + Send + Sync>>,
 {
     type Output = crate::Result<()>;
@@ -449,11 +450,11 @@ impl Builder {
     /// # }
     /// # fn main() {}
     /// ```
-    pub fn serve_connection<I, S>(&self, io: I, service: S) -> Connection<I, S>
+    pub fn serve_connection<'body, I, S>(&self, io: I, service: S) -> Connection<'body, I, S>
     where
         S: HttpService<IncomingBody>,
         S::Error: Into<Box<dyn StdError + Send + Sync>>,
-        S::ResBody: 'static,
+        S::ResBody: 'body,
         <S::ResBody as Body>::Error: Into<Box<dyn StdError + Send + Sync>>,
         I: Read + Write + Unpin,
     {
@@ -504,19 +505,19 @@ impl Builder {
 /// A future binding a connection with a Service with Upgrade support.
 #[must_use = "futures do nothing unless polled"]
 #[allow(missing_debug_implementations)]
-pub struct UpgradeableConnection<T, S>
+pub struct UpgradeableConnection<'body, T, S>
 where
     S: HttpService<IncomingBody>,
 {
-    pub(super) inner: Option<Connection<T, S>>,
+    pub(super) inner: Option<Connection<'body, T, S>>,
 }
 
-impl<I, B, S> UpgradeableConnection<I, S>
+impl<'body, I, B, S> UpgradeableConnection<'body, I, S>
 where
-    S: HttpService<IncomingBody, ResBody = B>,
+    S: HttpService<IncomingBody, ResBody = B> + 'body,
     S::Error: Into<Box<dyn StdError + Send + Sync>>,
-    I: Read + Write + Unpin,
-    B: Body + 'static,
+    I: Read + Write + Unpin + 'body,
+    B: Body + 'body,
     B::Error: Into<Box<dyn StdError + Send + Sync>>,
 {
     /// Start a graceful shutdown process for this connection.
@@ -538,12 +539,12 @@ where
     }
 }
 
-impl<I, B, S> Future for UpgradeableConnection<I, S>
+impl<'body, I, B, S> Future for UpgradeableConnection<'body, I, S>
 where
     S: HttpService<IncomingBody, ResBody = B>,
     S::Error: Into<Box<dyn StdError + Send + Sync>>,
     I: Read + Write + Unpin + Send + 'static,
-    B: Body + 'static,
+    B: Body + 'body,
     B::Error: Into<Box<dyn StdError + Send + Sync>>,
 {
     type Output = crate::Result<()>;
diff --git a/src/server/conn/http2.rs b/src/server/conn/http2.rs
index e4dac78bea..30e04fd921 100644
--- a/src/server/conn/http2.rs
+++ b/src/server/conn/http2.rs
@@ -26,11 +26,11 @@ pin_project! {
     /// To drive HTTP on this connection this future **must be polled**, typically with
     /// `.await`. If it isn't polled, no progress will be made on this connection.
     #[must_use = "futures do nothing unless polled"]
-    pub struct Connection<T, S, E>
+    pub struct Connection<'body, T, S, E>
     where
         S: HttpService<IncomingBody>,
     {
-        conn: proto::h2::Server<T, S, S::ResBody, E>,
+        conn: proto::h2::Server<'body, T, S, S::ResBody, E>,
     }
 }
 
@@ -47,7 +47,7 @@ pub struct Builder<E> {
 
 // ===== impl Connection =====
 
-impl<I, S, E> fmt::Debug for Connection<I, S, E>
+impl<'body, I, S, E> fmt::Debug for Connection<'body, I, S, E>
 where
     S: HttpService<IncomingBody>,
 {
@@ -56,12 +56,12 @@ where
     }
 }
 
-impl<I, B, S, E> Connection<I, S, E>
+impl<'body, I, B, S, E> Connection<'body, I, S, E>
 where
     S: HttpService<IncomingBody, ResBody = B>,
     S::Error: Into<Box<dyn StdError + Send + Sync>>,
     I: Read + Write + Unpin,
-    B: Body + 'static,
+    B: Body + 'body,
     B::Error: Into<Box<dyn StdError + Send + Sync>>,
     E: Http2ServerConnExec<S::Future, B>,
 {
@@ -80,12 +80,12 @@ where
     }
 }
 
-impl<I, B, S, E> Future for Connection<I, S, E>
+impl<'body, I, B, S, E> Future for Connection<'body, I, S, E>
 where
     S: HttpService<IncomingBody, ResBody = B>,
     S::Error: Into<Box<dyn StdError + Send + Sync>>,
     I: Read + Write + Unpin,
-    B: Body + 'static,
+    B: Body + 'body,
     B::Error: Into<Box<dyn StdError + Send + Sync>>,
     E: Http2ServerConnExec<S::Future, B>,
 {
@@ -303,11 +303,11 @@ impl<E> Builder<E> {
     ///
     /// This returns a Future that must be polled in order for HTTP to be
     /// driven on the connection.
-    pub fn serve_connection<S, I, Bd>(&self, io: I, service: S) -> Connection<I, S, E>
+    pub fn serve_connection<'body, S, I, Bd>(&self, io: I, service: S) -> Connection<'body, I, S, E>
     where
         S: HttpService<IncomingBody, ResBody = Bd>,
         S::Error: Into<Box<dyn StdError + Send + Sync>>,
-        Bd: Body + 'static,
+        Bd: Body + 'body,
         Bd::Error: Into<Box<dyn StdError + Send + Sync>>,
         I: Read + Write + Unpin,
         E: Http2ServerConnExec<S::Future, Bd>,