Decouple server::Error from MakeService

When server::Error is used in a generic way, but with a particular
specialization of its MakeService type parameter, the type parameters
and trait bounds of the specialization are included into the signature
of the specialized server::Error, even though they may have no bearing
on the actual variant error types.

Redefine server::Error with two generic type parameters that receive
associated types Error and MakeError of a MakeService impl,
sans the explicit trait bound. To reduce verbosity in the common
case when both parameters get the same type, the second parameter
defaults to the type of the first.

Author: mzabaluev

src/server/mod.rs

@@ -61,7 +61,7 @@ where T: AsyncRead + AsyncWrite,
     /// The service has closed, so poll until connection is closed.
     GoAway {
         connection: Accept<T, SendBuf<<B::Data as IntoBuf>::Buf>>,
-        error: Error<S>,
+        error: Error<S::Error, S::MakeError>,
     },
 
     /// Everything is closed up.
@@ -94,20 +94,19 @@ where B: Body,
 }
 
 /// Error produced by a `Connection`.
-pub enum Error<S>
-where S: MakeService<(), Request<RecvBody>>,
-{
+#[derive(Debug)]
+pub enum Error<E, ME = E> {
     /// Error produced during the HTTP/2.0 handshake.
     Handshake(h2::Error),
 
     /// Error produced by the HTTP/2.0 stream
     Protocol(h2::Error),
 
     /// Error produced when obtaining the service
-    NewService(S::MakeError),
+    NewService(ME),
 
     /// Error produced by the service
-    Service(S::Error),
+    Service(E),
 
     /// Error produced when attempting to spawn a task
     Execute,
@@ -200,7 +199,7 @@ where T: AsyncRead + AsyncWrite,
       F: Modify,
 {
     type Item = ();
-    type Error = Error<S>;
+    type Error = Error<S::Error, S::MakeError>;
 
     fn poll(&mut self) -> Poll<Self::Item, Self::Error> {
         // Code is in poll2 to make sure any Err returned
@@ -238,7 +237,7 @@ where T: AsyncRead + AsyncWrite,
         self.state = State::Done;
     }
 
-    fn poll2(&mut self) -> Poll<(), Error<S>> {
+    fn poll2(&mut self) -> Poll<(), Error<S::Error, S::MakeError>> {
         loop {
             match self.state {
                 State::Init(..) => try_ready!(self.poll_init()),
@@ -257,7 +256,7 @@ where T: AsyncRead + AsyncWrite,
         }
     }
 
-    fn poll_init(&mut self) -> Poll<(), Error<S>> {
+    fn poll_init(&mut self) -> Poll<(), Error<S::Error, S::MakeError>> {
         use self::State::*;
 
         let (connection, service) = match self.state {
@@ -270,7 +269,7 @@ where T: AsyncRead + AsyncWrite,
         Ok(().into())
     }
 
-    fn poll_main(&mut self) -> Poll<PollMain, Error<S>> {
+    fn poll_main(&mut self) -> Poll<PollMain, Error<S::Error, S::MakeError>> {
         let error = match self.state {
             State::Ready { ref mut connection, ref mut service } => loop {
                 // Make sure the service is ready
@@ -344,7 +343,7 @@ where T: AsyncRead + AsyncWrite,
         }
     }
 
-    fn poll_goaway(&mut self) -> Poll<(), Error<S>> {
+    fn poll_goaway(&mut self) -> Poll<(), Error<S::Error, S::MakeError>> {
         match self.state {
             State::GoAway { ref mut connection, .. } => {
                 try_ready!(connection.poll_close().map_err(Error::Protocol));
@@ -470,47 +469,19 @@ where T: Future<Item = Response<B>>,
 
 // ===== impl Error =====
 
-impl<S> Error<S>
-where S: MakeService<(), Request<RecvBody>>,
-{
-    fn from_init(err: Either<h2::Error, S::MakeError>) -> Self {
+impl<E, ME> Error<E, ME> {
+    fn from_init(err: Either<h2::Error, ME>) -> Self {
         match err {
             Either::A(err) => Error::Handshake(err),
             Either::B(err) => Error::NewService(err),
         }
     }
 }
 
-impl<S> fmt::Debug for Error<S>
-where
-    S: MakeService<(), Request<RecvBody>>,
-    S::MakeError: fmt::Debug,
-    S::Error: fmt::Debug,
-{
-    fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
-        match *self {
-            Error::Handshake(ref why) => f.debug_tuple("Handshake")
-                .field(why)
-                .finish(),
-            Error::Protocol(ref why) => f.debug_tuple("Protocol")
-                .field(why)
-                .finish(),
-            Error::NewService(ref why) => f.debug_tuple("NewService")
-                .field(why)
-                .finish(),
-            Error::Service(ref why) => f.debug_tuple("Service")
-                .field(why)
-                .finish(),
-            Error::Execute => f.debug_tuple("Execute").finish(),
-        }
-    }
-}
-
-impl<S> fmt::Display for Error<S>
+impl<E, ME> fmt::Display for Error<E, ME>
 where
-    S: MakeService<(), Request<RecvBody>>,
-    S::MakeError: fmt::Display,
-    S::Error: fmt::Display,
+    E: fmt::Display,
+    ME: fmt::Display,
 {
     fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
         match *self {
@@ -528,11 +499,10 @@ where
     }
 }
 
-impl<S> error::Error for Error<S>
+impl<E, ME> error::Error for Error<E, ME>
 where
-    S: MakeService<(), Request<RecvBody>>,
-    S::MakeError: error::Error,
-    S::Error: error::Error,
+    E: error::Error,
+    ME: error::Error,
 {
     fn cause(&self) -> Option<&error::Error> {
         match *self {