stream.rs

    let jobs = myvec
        .into_iter()
        .map(|url| {
            // we use the end of the supplied URL to create the directory
            let uri = url.parse::<Uri>().unwrap();
            let p = uri.path();
            let segments = p.split('/').collect::<Vec<_>>();
            let end = &segments[segments.len() - 4..];
            let fullpath = Path::new(&ctx.config.data_dir).join(end.join("/"));
            std::fs::create_dir_all(fullpath.parent().unwrap()).unwrap();
            requests::fetch_to_disk(uri, fullpath)
        });
    let fut = futures::stream::futures_unordered(jobs).collect();
    let _result = runtime.block_on(fut).unwrap();