From 9b69fa9740ef2b04521344c9d9ca6015545ef7af Mon Sep 17 00:00:00 2001
From: Sean McArthur <sean@seanmonstar.com>
Date: Tue, 11 Dec 2018 15:59:35 -0800
Subject: [PATCH] refactor(http2): make several http2 errors more specific

---
 src/proto/h2/client.rs |  2 +-
 src/proto/h2/mod.rs    | 10 +++++-----
 2 files changed, 6 insertions(+), 6 deletions(-)

diff --git a/src/proto/h2/client.rs b/src/proto/h2/client.rs
index 7ccceac0..9fd231b0 100644
--- a/src/proto/h2/client.rs
+++ b/src/proto/h2/client.rs
@@ -117,7 +117,7 @@ where
                                 Ok(ok) => ok,
                                 Err(err) => {
                                     debug!("client send request error: {}", err);
-                                    let _ = cb.send(Err((::Error::new_h2(err), None)));
+                                    let _ = cb.send(Err((::Error::new_canceled(err), None)));
                                     continue;
                                 }
                             };
diff --git a/src/proto/h2/mod.rs b/src/proto/h2/mod.rs
index a1863b23..072799d8 100644
--- a/src/proto/h2/mod.rs
+++ b/src/proto/h2/mod.rs
@@ -123,7 +123,7 @@ where
 
                 if self.body_tx.capacity() == 0 {
                     loop {
-                        match try_ready!(self.body_tx.poll_capacity().map_err(::Error::new_h2)) {
+                        match try_ready!(self.body_tx.poll_capacity().map_err(::Error::new_body_write)) {
                             Some(0) => {}
                             Some(_) => break,
                             None => return Err(::Error::new_canceled(None::<::Error>)),
@@ -131,10 +131,10 @@ where
                     }
                 } else {
                     if let Async::Ready(reason) =
-                        self.body_tx.poll_reset().map_err(|e| ::Error::new_h2(e))?
+                        self.body_tx.poll_reset().map_err(::Error::new_body_write)?
                     {
                         debug!("stream received RST_STREAM: {:?}", reason);
-                        return Err(::Error::new_h2(reason.into()));
+                        return Err(::Error::new_body_write(::h2::Error::from(reason)));
                     }
                 }
 
@@ -169,10 +169,10 @@ where
                 }
             } else {
                 if let Async::Ready(reason) =
-                    self.body_tx.poll_reset().map_err(|e| ::Error::new_h2(e))?
+                    self.body_tx.poll_reset().map_err(|e| ::Error::new_body_write(e))?
                 {
                     debug!("stream received RST_STREAM: {:?}", reason);
-                    return Err(::Error::new_h2(reason.into()));
+                    return Err(::Error::new_body_write(::h2::Error::from(reason)));
                 }
 
                 match try_ready!(self.stream.poll_trailers().map_err(|e| self.on_err(e))) {