aboutsummaryrefslogtreecommitdiffstats
path: root/components/net/file_loader.rs
diff options
context:
space:
mode:
authorSean McArthur <sean.monstar@gmail.com>2014-09-04 20:34:00 -0700
committerSean McArthur <sean.monstar@gmail.com>2014-09-11 08:55:54 -0700
commitb8b51b6dd85b047bbfc25b3c88c5910cd3bfbfa1 (patch)
tree77b5378925761d5f3313ba00155948246565539d /components/net/file_loader.rs
parentf3653342df0f574f3f2c6bbcbecc67c6de9f84bf (diff)
downloadservo-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.rs45
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())));
+ }
+ }
+ });
}