diff options
author | Josh Matthews <josh@joshmatthews.net> | 2015-01-15 13:26:44 -0500 |
---|---|---|
committer | Glenn Watson <gw@intuitionlibrary.com> | 2015-01-28 10:16:49 +1000 |
commit | 95fc29fa0db21959df99d81cdbb9561226321d2f (patch) | |
tree | a48e171165ec155062ef13c550b2c0f72d127425 /components/net/data_loader.rs | |
parent | ff8cbff81016c157373c1675f3eee69dd70ae544 (diff) | |
download | servo-95fc29fa0db21959df99d81cdbb9561226321d2f.tar.gz servo-95fc29fa0db21959df99d81cdbb9561226321d2f.zip |
Update rustc to 00b112c45a604fa6f4b59af2a40c9deeadfdb7c6/rustc-1.0.0-dev.
Diffstat (limited to 'components/net/data_loader.rs')
-rw-r--r-- | components/net/data_loader.rs | 13 |
1 files changed, 7 insertions, 6 deletions
diff --git a/components/net/data_loader.rs b/components/net/data_loader.rs index b24c58e4b71..da58515a7ad 100644 --- a/components/net/data_loader.rs +++ b/components/net/data_loader.rs @@ -10,6 +10,7 @@ use serialize::base64::FromBase64; use hyper::mime::Mime; use url::{percent_decode, SchemeData}; +use std::sync::mpsc::Sender; pub fn factory(load_data: LoadData, start_chan: Sender<TargetedLoadResponse>) { // NB: we don't spawn a new task. @@ -59,7 +60,7 @@ fn load(load_data: LoadData, start_chan: Sender<TargetedLoadResponse>) { // Parse the content type using rust-http. // FIXME: this can go into an infinite loop! (rust-http #25) - let content_type: Option<Mime> = from_str(ct_str); + let content_type: Option<Mime> = ct_str.parse(); metadata.set_content_type(content_type.as_ref()); let progress_chan = start_sending(senders, metadata); @@ -89,19 +90,19 @@ fn assert_parse(url: &'static str, content_type: Option<(String, String)>, charset: Option<String>, data: Option<Vec<u8>>) { - use std::comm; + use std::sync::mpsc::channel; use url::Url; use sniffer_task; - let (start_chan, start_port) = comm::channel(); + let (start_chan, start_port) = channel(); let sniffer_task = sniffer_task::new_sniffer_task(); load(LoadData::new(Url::parse(url).unwrap(), start_chan), sniffer_task); - let response = start_port.recv(); + let response = start_port.recv().unwrap(); assert_eq!(&response.metadata.content_type, &content_type); assert_eq!(&response.metadata.charset, &charset); - let progress = response.progress_port.recv(); + let progress = response.progress_port.recv().unwrap(); match data { None => { @@ -109,7 +110,7 @@ fn assert_parse(url: &'static str, } Some(dat) => { assert_eq!(progress, Payload(dat)); - assert_eq!(response.progress_port.recv(), Done(Ok(()))); + assert_eq!(response.progress_port.recv().unwrap(), Done(Ok(()))); } } } |