download.rs

use super::downloader::HttpClient;
use hyper::client::ResponseFuture;
use hyper::rt::Future;
use hyper::Uri;

enum DownloadStatus {
    Idle,
    PendingResponse,
    PendingBody,
    Completed,
    Errored,
}

pub struct Download {
    uri: String,
    status: DownloadStatus,
    future: ResponseFuture,
}

impl Download {
    pub fn new(uri: &str, client: &HttpClient) -> Download {
        let parsed_uri: Uri = uri.parse().unwrap();

        Download {
            uri: uri.to_owned(),
            status: DownloadStatus::Idle,
            future: client.get(parsed_uri),
        }
    }

    pub fn future(&mut self) -> impl Future {
                                ^^^^^^^^^^^ lifetime of return value does not outlive the function call
        self.status = DownloadStatus::PendingResponse;

        self.future.map(|res| {
            self.status = if res.status().is_success() {
                DownloadStatus::PendingResponse
            } else {
                DownloadStatus::Errored
            };

            res.body()
        })
    }
}