address nits

Signed-off-by: Brian L. Troutwine <brian@troutwine.us>
vectordotdev · Feb 9, 2022 · 4b1e68a · 4b1e68a
1 parent 9397baa
commit 4b1e68a
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/lib/vector-core/src/fanout.rs b/lib/vector-core/src/fanout.rs
@@ -74,11 +74,12 @@ impl Fanout {
                 sink.flush().await?;
             }
         } else {
-            let mut faulty_sinks = Vec::with_capacity(0);
+            let mut faulty_sinks = Vec::new();
 
             {
                 let mut jobs = FuturesUnordered::new();
-                let mut clone_army: Vec<Vec<Event>> = Vec::with_capacity(self.sinks.len());
+                let mut clone_army: Vec<Vec<Event>> =
+                    Vec::with_capacity(self.sinks.iter().filter(|x| x.1.is_some()).count());
                 for _ in 0..(self.sinks.len() - 1) {
                     clone_army.push(events.clone());
                 }