aboutsummaryrefslogtreecommitdiffstats
path: root/components/net/tests/http_loader.rs
diff options
context:
space:
mode:
Diffstat (limited to 'components/net/tests/http_loader.rs')
-rw-r--r--components/net/tests/http_loader.rs28
1 files changed, 5 insertions, 23 deletions
diff --git a/components/net/tests/http_loader.rs b/components/net/tests/http_loader.rs
index e9de2cb983f..e84b0ec3fc5 100644
--- a/components/net/tests/http_loader.rs
+++ b/components/net/tests/http_loader.rs
@@ -15,7 +15,6 @@ use devtools_traits::HttpResponse as DevtoolsHttpResponse;
use devtools_traits::{ChromeToDevtoolsControlMsg, DevtoolsControlMsg, NetworkEvent};
use flate2::write::{DeflateEncoder, GzEncoder};
use flate2::Compression;
-use futures::{self, Future, Stream};
use headers::authorization::Basic;
use headers::{
Authorization, ContentLength, Date, HeaderMapExt, Host, StrictTransportSecurity, UserAgent,
@@ -23,7 +22,7 @@ use headers::{
use http::header::{self, HeaderMap, HeaderValue};
use http::uri::Authority;
use http::{Method, StatusCode};
-use hyper::body::Body;
+use hyper::Body;
use hyper::{Request as HyperRequest, Response as HyperResponse};
use ipc_channel::ipc;
use ipc_channel::router::ROUTER;
@@ -51,13 +50,6 @@ fn mock_origin() -> ImmutableOrigin {
ServoUrl::parse("http://servo.org").unwrap().origin()
}
-fn read_response(req: HyperRequest<Body>) -> impl Future<Item = String, Error = ()> {
- req.into_body()
- .concat2()
- .and_then(|body| futures::future::ok(str::from_utf8(&body).unwrap().to_owned()))
- .map_err(|_| ())
-}
-
fn assert_cookie_for_domain(
cookie_jar: &RwLock<CookieStorage>,
domain: &str,
@@ -521,28 +513,18 @@ fn test_load_should_decode_the_response_as_gzip_when_response_headers_have_conte
#[test]
fn test_load_doesnt_send_request_body_on_any_redirect() {
+ use hyper::body::HttpBody;
+
let post_handler = move |request: HyperRequest<Body>, response: &mut HyperResponse<Body>| {
assert_eq!(request.method(), Method::GET);
- read_response(request)
- .and_then(|data| {
- assert_eq!(data, "");
- futures::future::ok(())
- })
- .poll()
- .unwrap();
+ assert_eq!(request.size_hint().exact(), Some(0));
*response.body_mut() = b"Yay!".to_vec().into();
};
let (post_server, post_url) = make_server(post_handler);
let post_redirect_url = post_url.clone();
let pre_handler = move |request: HyperRequest<Body>, response: &mut HyperResponse<Body>| {
- read_response(request)
- .and_then(|data| {
- assert_eq!(data, "Body on POST");
- futures::future::ok(())
- })
- .poll()
- .unwrap();
+ assert_eq!(request.size_hint().exact(), Some(13));
response.headers_mut().insert(
header::LOCATION,
HeaderValue::from_str(&post_redirect_url.to_string()).unwrap(),