Fix deadlock

Timo Freiberg · Timo Freiberg · commit 28ad6839076f · 2021-10-09T19:14:17.000+02:00
diff --git a/lychee-bin/src/main.rs b/lychee-bin/src/main.rs
@@ -67,7 +67,7 @@ use std::iter::FromIterator;
 use std::{collections::HashSet, fs, str::FromStr};
 
 use anyhow::{anyhow, Context, Result};
-use futures::{pin_mut, stream::TryStreamExt};
+use futures::stream::TryStreamExt;
 use headers::HeaderMapExt;
 use indicatif::{ProgressBar, ProgressStyle};
 use lychee_lib::{Client, ClientBuilder, Collector, Input, Request, Response};
@@ -271,7 +271,7 @@ async fn run(cfg: &Config, inputs: Vec<Input>) -> Result<i32> {
         }
     });
 
-    pin_mut!(links);
+    tokio::pin!(links);
     while let Some(link) = links.next().await {
         let link = link?;
         if let Some(pb) = &bar {
@@ -280,6 +280,9 @@ async fn run(cfg: &Config, inputs: Vec<Input>) -> Result<i32> {
         };
         send_req.send(link).await.unwrap();
     }
+    // required for the receiver task to end, which closes send_resp, which allows
+    // the show_results_task to finish
+    drop(send_req);
 
     let (pb, stats) = show_results_task.await?;
 
