aboutsummaryrefslogtreecommitdiffstats
path: root/components/net/fetch/methods.rs
diff options
context:
space:
mode:
authorNaveen Gattu <naveen.gattu@gmail.com>2021-12-23 11:15:35 -0800
committerNaveen Gattu <naveen.gattu@gmail.com>2022-01-16 09:34:17 -0800
commita48a111cee6298f4628d4ae12b60a43c1b17cecf (patch)
treeaf1ff0300471853886267631e2d66c937a604e9e /components/net/fetch/methods.rs
parent5df705a41f6c4c1f2ffeec257dfe0129ce5fa8e0 (diff)
downloadservo-a48a111cee6298f4628d4ae12b60a43c1b17cecf.tar.gz
servo-a48a111cee6298f4628d4ae12b60a43c1b17cecf.zip
Upgrade Hyper
Diffstat (limited to 'components/net/fetch/methods.rs')
-rw-r--r--components/net/fetch/methods.rs10
1 files changed, 6 insertions, 4 deletions
diff --git a/components/net/fetch/methods.rs b/components/net/fetch/methods.rs
index a7d82cac318..cf99b0d8adb 100644
--- a/components/net/fetch/methods.rs
+++ b/components/net/fetch/methods.rs
@@ -14,8 +14,8 @@ use crossbeam_channel::Sender;
use devtools_traits::DevtoolsControlMsg;
use headers::{AccessControlExposeHeaders, ContentType, HeaderMapExt, Range};
use http::header::{self, HeaderMap, HeaderName};
-use hyper::Method;
-use hyper::StatusCode;
+use http::Method;
+use http::StatusCode;
use ipc_channel::ipc::{self, IpcReceiver};
use mime::{self, Mime};
use net_traits::blob_url_store::{parse_blob_url, BlobURLStoreError};
@@ -40,7 +40,7 @@ use std::ops::Bound;
use std::str;
use std::sync::atomic::Ordering;
use std::sync::{Arc, Mutex};
-use tokio2::sync::mpsc::{
+use tokio::sync::mpsc::{
unbounded_channel, UnboundedReceiver as TokioReceiver, UnboundedSender as TokioSender,
};
@@ -522,7 +522,9 @@ async fn wait_for_response(
Some(Data::Payload(vec)) => {
target.process_response_chunk(vec);
},
- Some(Data::Done) => break,
+ Some(Data::Done) => {
+ break;
+ },
Some(Data::Cancelled) => {
response.aborted.store(true, Ordering::Release);
break;