diff --git a/src/async_impl/client.rs b/src/async_impl/client.rs index 56e0ed2..ccd6514 100644 --- a/src/async_impl/client.rs +++ b/src/async_impl/client.rs @@ -407,7 +407,7 @@ enum PendingInner { Error(Option<::Error>), } -pub struct PendingRequest { +struct PendingRequest { method: Method, url: Url, headers: HeaderMap, @@ -420,6 +420,13 @@ pub struct PendingRequest { in_flight: ResponseFuture, } +impl Pending { + pub(super) fn new_err(err: ::Error) -> Pending { + Pending { + inner: PendingInner::Error(Some(err)), + } + } +} impl Future for Pending { type Item = Response; @@ -551,10 +558,3 @@ fn make_referer(next: &Url, previous: &Url) -> Option { referer.as_str().parse().ok() } -// pub(crate) - -pub fn pending_err(err: ::Error) -> Pending { - Pending { - inner: PendingInner::Error(Some(err)), - } -} diff --git a/src/async_impl/request.rs b/src/async_impl/request.rs index 422ee86..8ce665d 100644 --- a/src/async_impl/request.rs +++ b/src/async_impl/request.rs @@ -6,7 +6,7 @@ use serde_json; use serde_urlencoded; use super::body::{Body}; -use super::client::{Client, Pending, pending_err}; +use super::client::{Client, Pending}; use header::{CONTENT_TYPE, HeaderMap, HeaderName, HeaderValue}; use http::HttpTryFrom; use {Method, Url}; @@ -277,7 +277,7 @@ impl RequestBuilder { pub fn send(self) -> Pending { match self.request { Ok(req) => self.client.execute(req), - Err(err) => pending_err(err), + Err(err) => Pending::new_err(err), } } }