Update lib/vector-core/src/fanout.rs

Co-authored-by: Luke Steensen <luke.steensen@gmail.com>
vectordotdev · Feb 8, 2022 · 34120c0 · 34120c0
1 parent 1a45458
commit 34120c0
Showing 1 changed file with 2 additions and 5 deletions.
diff --git a/lib/vector-core/src/fanout.rs b/lib/vector-core/src/fanout.rs
@@ -80,11 +80,8 @@ impl Fanout {
                 }
 
                 while let Some(res) = jobs.next().await {
-                    match res {
-                        Ok(()) => continue,
-                        Err((id, ())) => {
-                            faulty_sinks.push(id);
-                        }
+                    if let Err((id, ())) = res {
+                        faulty_sinks.push(id);
                     }
                 }
             }