diff --git a/tower/src/buffer/layer.rs b/tower/src/buffer/layer.rs
index 01e7100..b744cb1 100644
--- a/tower/src/buffer/layer.rs
+++ b/tower/src/buffer/layer.rs
@@ -33,7 +33,6 @@ impl<Request, E2> BufferLayer<Request, E2> {
         BufferLayer {
             bound,
             _p: PhantomData,
-            _e: PhantomData,
         }
     }
 }
@@ -51,7 +50,7 @@ where
     type Service = Buffer<S, Request, E2>;
 
     fn layer(&self, service: S) -> Self::Service {
-        Buffer::new(service, self.bound)
+        Buffer::new2(service, self.bound)
     }
 }
 
diff --git a/tower/src/buffer/service.rs b/tower/src/buffer/service.rs
index 06d4c55..1ab4d22 100644
--- a/tower/src/buffer/service.rs
+++ b/tower/src/buffer/service.rs
@@ -21,6 +21,43 @@ where
     handle: Handle<S::Error, E2>,
 }
 
+impl<S, Request> Buffer<S, Request, crate::BoxError>
+where
+    S: Service<Request>,
+    S::Error: Into<crate::BoxError> + Clone,
+    crate::buffer::error::Closed: Into<crate::BoxError>,
+{
+    /// Creates a new `Buffer` wrapping `service`.
+    ///
+    /// `bound` gives the maximal number of requests that can be queued for the service before
+    /// backpressure is applied to callers.
+    ///
+    /// The default Tokio executor is used to run the given service, which means that this method
+    /// must be called while on the Tokio runtime.
+    ///
+    /// # A note on choosing a `bound`
+    ///
+    /// When `Buffer`'s implementation of `poll_ready` returns `Poll::Ready`, it reserves a
+    /// slot in the channel for the forthcoming `call()`. However, if this call doesn't arrive,
+    /// this reserved slot may be held up for a long time. As a result, it's advisable to set
+    /// `bound` to be at least the maximum number of concurrent requests the `Buffer` will see.
+    /// If you do not, all the slots in the buffer may be held up by futures that have just called
+    /// `poll_ready` but will not issue a `call`, which prevents other senders from issuing new
+    /// requests.
+    pub fn new(service: S, bound: usize) -> Self
+    where
+        S: Send + 'static,
+        S::Future: Send,
+        S::Error: Send + Sync + std::fmt::Display,
+        Request: Send + 'static,
+    {
+        let (tx, rx) = mpsc::channel(bound);
+        let (handle, worker) = Worker::new(service, rx);
+        tokio::spawn(worker);
+        Buffer { tx, handle }
+    }
+}
+
 impl<S, Request, E2> Buffer<S, Request, E2>
 where
     S: Service<Request>,
@@ -45,7 +82,7 @@ where
     /// If you do not, all the slots in the buffer may be held up by futures that have just called
     /// `poll_ready` but will not issue a `call`, which prevents other senders from issuing new
     /// requests.
-    pub fn new(service: S, bound: usize) -> Self
+    pub fn new2(service: S, bound: usize) -> Self
     where
         S: Send + 'static,
         S::Future: Send,