Upgrade dependancies.

hammond-data/Cargo.toml

@@ -14,16 +14,16 @@ itertools = "0.7.6"
 lazy_static = "1.0.0"
 log = "0.4.1"
 rayon = "0.9.0"
-reqwest = "0.8.2"
+reqwest = "0.8.3"
 rfc822_sanitizer = "0.3.3"
 rss = "1.2.1"
 url = "1.6.0"
 xdg = "2.1.0"
 futures = "0.1.17"
-hyper = "0.11.12"
+hyper = "0.11.14"
 tokio-core = "0.1.12"
 hyper-tls = "0.1.2"
-native-tls = "0.1.4"
+native-tls = "0.1.5"
 
 [dependencies.diesel]
 features = ["sqlite", "r2d2"]
@@ -34,7 +34,7 @@ features = ["sqlite"]
 version = "1.1.0"
 
 [dev-dependencies]
-rand = "0.4.1"
+rand = "0.4.2"
 tempdir = "0.3.5"
 criterion = "0.1.2"
 

hammond-data/src/pipeline.rs

@@ -2,6 +2,7 @@
 //! Docs.
 
 use futures::future::*;
+// use futures_cpupool::CpuPool;
 // use futures::prelude::*;
 
 use hyper::Client;
@@ -17,6 +18,7 @@ use models::{IndexState, NewEpisode, NewEpisodeMinimal};
 // use Feed;
 
 use std;
+// use std::sync::{Arc, Mutex};
 
 /// The pipline to be run for indexing and updating a Podcast feed that originates from
 /// `Source.uri`.
@@ -25,6 +27,8 @@ use std;
 /// Source -> GET Request -> Update Etags -> Check Status -> Parse xml/Rss ->
 /// Convert `rss::Channel` into Feed -> Index Podcast -> Index Episodes.
 pub fn pipeline<S: IntoIterator<Item = Source>>(sources: S, ignore_etags: bool) -> Result<()> {
+    // let _pool = CpuPool::new_num_cpus();
+
     let mut core = Core::new()?;
     let handle = core.handle();
     let client = Client::configure()