pub(crate)ify the async::client module
This commit is contained in:
@@ -407,7 +407,7 @@ enum PendingInner {
|
|||||||
Error(Option<::Error>),
|
Error(Option<::Error>),
|
||||||
}
|
}
|
||||||
|
|
||||||
pub struct PendingRequest {
|
struct PendingRequest {
|
||||||
method: Method,
|
method: Method,
|
||||||
url: Url,
|
url: Url,
|
||||||
headers: HeaderMap,
|
headers: HeaderMap,
|
||||||
@@ -420,6 +420,13 @@ pub struct PendingRequest {
|
|||||||
in_flight: ResponseFuture,
|
in_flight: ResponseFuture,
|
||||||
}
|
}
|
||||||
|
|
||||||
|
impl Pending {
|
||||||
|
pub(super) fn new_err(err: ::Error) -> Pending {
|
||||||
|
Pending {
|
||||||
|
inner: PendingInner::Error(Some(err)),
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
impl Future for Pending {
|
impl Future for Pending {
|
||||||
type Item = Response;
|
type Item = Response;
|
||||||
@@ -551,10 +558,3 @@ fn make_referer(next: &Url, previous: &Url) -> Option<HeaderValue> {
|
|||||||
referer.as_str().parse().ok()
|
referer.as_str().parse().ok()
|
||||||
}
|
}
|
||||||
|
|
||||||
// pub(crate)
|
|
||||||
|
|
||||||
pub fn pending_err(err: ::Error) -> Pending {
|
|
||||||
Pending {
|
|
||||||
inner: PendingInner::Error(Some(err)),
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|||||||
@@ -6,7 +6,7 @@ use serde_json;
|
|||||||
use serde_urlencoded;
|
use serde_urlencoded;
|
||||||
|
|
||||||
use super::body::{Body};
|
use super::body::{Body};
|
||||||
use super::client::{Client, Pending, pending_err};
|
use super::client::{Client, Pending};
|
||||||
use header::{CONTENT_TYPE, HeaderMap, HeaderName, HeaderValue};
|
use header::{CONTENT_TYPE, HeaderMap, HeaderName, HeaderValue};
|
||||||
use http::HttpTryFrom;
|
use http::HttpTryFrom;
|
||||||
use {Method, Url};
|
use {Method, Url};
|
||||||
@@ -277,7 +277,7 @@ impl RequestBuilder {
|
|||||||
pub fn send(self) -> Pending {
|
pub fn send(self) -> Pending {
|
||||||
match self.request {
|
match self.request {
|
||||||
Ok(req) => self.client.execute(req),
|
Ok(req) => self.client.execute(req),
|
||||||
Err(err) => pending_err(err),
|
Err(err) => Pending::new_err(err),
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user