diff options
Diffstat (limited to 'components/net/file_loader.rs')
| -rw-r--r-- | components/net/file_loader.rs | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/components/net/file_loader.rs b/components/net/file_loader.rs index 73bab50c54d..a2233ff54b8 100644 --- a/components/net/file_loader.rs +++ b/components/net/file_loader.rs @@ -8,6 +8,7 @@ use resource_task::ProgressMsg::{Payload, Done}; use std::borrow::ToOwned; use std::io; use std::io::File; +use std::sync::mpsc::Sender; use servo_util::task::spawn_named; static READ_SIZE: uint = 8192; @@ -17,11 +18,11 @@ fn read_all(reader: &mut io::Stream, progress_chan: &Sender<ProgressMsg>) loop { let mut buf = vec!(); match reader.push_at_least(READ_SIZE, READ_SIZE, &mut buf) { - Ok(_) => progress_chan.send(Payload(buf)), + Ok(_) => progress_chan.send(Payload(buf)).unwrap(), Err(e) => match e.kind { io::EndOfFile => { if buf.len() > 0 { - progress_chan.send(Payload(buf)); + progress_chan.send(Payload(buf)).unwrap(); } return Ok(()); } @@ -39,7 +40,7 @@ pub fn factory(load_data: LoadData, start_chan: Sender<TargetedLoadResponse>) { eventual_consumer: load_data.consumer, }; let progress_chan = start_sending(senders, Metadata::default(url.clone())); - spawn_named("file_loader".to_owned(), proc() { + spawn_named("file_loader".to_owned(), move || { let file_path: Result<Path, ()> = url.to_file_path(); match file_path { Ok(file_path) => { |