download.rs

use super::downloader::HttpClient;
use hyper::rt::{Future, Stream};
use hyper::Uri;
use std::sync::Arc;

pub struct Download {
    uri: String,
    data: Arc<Vec<u8>>,
}

impl Download {
    pub fn new(uri: &str) -> Download {
        Download {
            uri: uri.to_owned(),
            data: Arc::new(Vec::new()),
        }
    }

    pub fn make_future<'a>(
        &'a mut self,
        client: &HttpClient,
    ) -> impl Future<Item = (), Error = ()> + 'a {
        let parsed_uri: Uri = self.uri.parse().unwrap();
        let data = Arc::make_mut(&mut self.data);

        client
            .get(parsed_uri)
            .map(|res| {
                // ^^^^
                // closure may outlive the current function, but it borrows
                // `data`, which is owned by the current function: may outlive
                // borrowed value `data`
                res.into_body().and_then(|chunk| {
                    data.extend(chunk);
                    // ^^
                    Ok(())
                });
            })
            .map_err(|_| ())
    }
}