small

Cargo.lock

@@ -579,7 +579,7 @@ checksum = "388a1df253eca08550bef6c72392cfe7c30914bf41df5269b68cbd6ff8f570a3"
 
 [[package]]
 name = "sever"
-version = "1.0.0"
+version = "1.0.1"
 dependencies = [
  "cfg-if",
  "color-eyre",

Cargo.toml

@@ -1,7 +1,7 @@
 [package]
 name = "sever"
 description = "Coerce hardlinks into new files"
-version = "1.0.0"
+version = "1.0.1"
 authors = ["Avril <flanchan@cumallover.me>"]
 edition = "2018"
 readme = "README.org"

src/main.rs

@@ -71,7 +71,7 @@ async fn main() -> eyre::Result<()> {
 				       .dedup())
 			  .filter_map(|file| {
 			      async move {
-				  Some(parallel::expand_dir(file).await)
+				  Some(parallel::expand_dir(file).await) //TODO: We gotta in here, too
 			      }
 			  }).flatten()).await,
 	   "Jobs failed")

src/parallel.rs

@@ -98,7 +98,7 @@ async fn join_stream<I: Stream>(stream: I) -> impl Iterator<Item=<I::Item as Fut
 where I::Item: Future
 {
     //gotta be a better way than heap allocating here, right?
-    stream.then(|x| async move { x.await }).collect::<Vec<_>>().await.into_iter()
+    join_all(stream.collect::<Vec<_>>().await.into_iter()).await.into_iter() //TODO: We need to de-dupe this
 }
 
 pub async fn main<I: Stream<Item=String>>(list: I) -> eyre::Result<()>
@@ -213,7 +213,7 @@ pub async fn expand_dir(p: String) -> impl Stream<Item=String>
 		    tx.send(p).await.unwrap();
 		}
 	    });
-	    rx	
+	    rx //TODO: map this to dedup
 	} else {
 	    stream::iter(iter::once(p).filter_map(|p| {
 		if Path::new(&p).is_dir() {