diff options
author | Sean McArthur <sean.monstar@gmail.com> | 2014-09-04 20:34:00 -0700 |
---|---|---|
committer | Sean McArthur <sean.monstar@gmail.com> | 2014-09-11 08:55:54 -0700 |
commit | b8b51b6dd85b047bbfc25b3c88c5910cd3bfbfa1 (patch) | |
tree | 77b5378925761d5f3313ba00155948246565539d /components/net/file_loader.rs | |
parent | f3653342df0f574f3f2c6bbcbecc67c6de9f84bf (diff) | |
download | servo-b8b51b6dd85b047bbfc25b3c88c5910cd3bfbfa1.tar.gz servo-b8b51b6dd85b047bbfc25b3c88c5910cd3bfbfa1.zip |
remove unnecessary proc from resource loader factory
Diffstat (limited to 'components/net/file_loader.rs')
-rw-r--r-- | components/net/file_loader.rs | 45 |
1 files changed, 21 insertions, 24 deletions
diff --git a/components/net/file_loader.rs b/components/net/file_loader.rs index 73a1d81cc27..c08f6f90ee8 100644 --- a/components/net/file_loader.rs +++ b/components/net/file_loader.rs @@ -2,7 +2,7 @@ * License, v. 2.0. If a copy of the MPL was not distributed with this * file, You can obtain one at http://mozilla.org/MPL/2.0/. */ -use resource_task::{ProgressMsg, Metadata, Payload, Done, LoaderTask, start_sending}; +use resource_task::{ProgressMsg, Metadata, Payload, Done, start_sending}; use std::io; use std::io::File; @@ -29,30 +29,27 @@ fn read_all(reader: &mut io::Stream, progress_chan: &Sender<ProgressMsg>) } } -pub fn factory() -> LoaderTask { - let f: LoaderTask = proc(load_data, start_chan) { - let url = load_data.url; - assert!("file" == url.scheme.as_slice()); - let progress_chan = start_sending(start_chan, Metadata::default(url.clone())); - spawn_named("file_loader", proc() { - let file_path: Result<Path, ()> = url.to_file_path(); - match file_path { - Ok(file_path) => { - match File::open_mode(&Path::new(file_path), io::Open, io::Read) { - Ok(ref mut reader) => { - let res = read_all(reader as &mut io::Stream, &progress_chan); - progress_chan.send(Done(res)); - } - Err(e) => { - progress_chan.send(Done(Err(e.desc.to_string()))); - } +pub fn factory(load_data: LoadData, start_chan: Sender<LoadResponse>) { + let url = load_data.url; + assert!("file" == url.scheme.as_slice()); + let progress_chan = start_sending(start_chan, Metadata::default(url.clone())); + spawn_named("file_loader", proc() { + let file_path: Result<Path, ()> = url.to_file_path(); + match file_path { + Ok(file_path) => { + match File::open_mode(&Path::new(file_path), io::Open, io::Read) { + Ok(ref mut reader) => { + let res = read_all(reader as &mut io::Stream, &progress_chan); + progress_chan.send(Done(res)); + } + Err(e) => { + progress_chan.send(Done(Err(e.desc.to_string()))); } - } - Err(_) => { - progress_chan.send(Done(Err(url.to_string()))); } } - }); - }; - f + Err(_) => { + progress_chan.send(Done(Err(url.to_string()))); + } + } + }); } |