tests save error handling are go

Signed-off-by: Brian L. Troutwine <brian@troutwine.us>
vectordotdev · Feb 7, 2022 · 7f1ebb4 · 7f1ebb4
1 parent b167744
commit 7f1ebb4
Showing 1 changed file with 9 additions and 4 deletions.
diff --git a/lib/vector-core/src/fanout.rs b/lib/vector-core/src/fanout.rs
@@ -375,12 +375,13 @@ mod tests {
         fanout.add(ComponentKey::from("a"), Box::pin(tx_a));
         fanout.add(ComponentKey::from("b"), Box::pin(tx_b));
         fanout.add(ComponentKey::from("c"), Box::pin(tx_c));
-        // HERE
 
         let recs = make_events(3);
         let items = recs.clone();
         tokio::spawn(async move {
-            fanout.send_all(items).await.unwrap();
+            fanout.send_all(vec![items[0].clone()]).await.unwrap();
+            fanout.send_all(vec![items[1].clone()]).await.unwrap();
+            fanout.send_all(vec![items[2].clone()]).await.unwrap();
         });
 
         sleep(Duration::from_millis(50)).await;
@@ -413,7 +414,9 @@ mod tests {
         let recs = make_events(3);
         let items = recs.clone();
         tokio::spawn(async move {
-            fanout.send_all(items).await.unwrap();
+            fanout.send_all(vec![items[0].clone()]).await.unwrap();
+            fanout.send_all(vec![items[1].clone()]).await.unwrap();
+            fanout.send_all(vec![items[2].clone()]).await.unwrap();
         });
 
         sleep(Duration::from_millis(50)).await;
@@ -446,7 +449,9 @@ mod tests {
         let recs = make_events(3);
         let items = recs.clone();
         tokio::spawn(async move {
-            fanout.send_all(items).await.unwrap();
+            fanout.send_all(vec![items[0].clone()]).await.unwrap();
+            fanout.send_all(vec![items[1].clone()]).await.unwrap();
+            fanout.send_all(vec![items[2].clone()]).await.unwrap();
         });
 
         sleep(Duration::from_millis(50)).await;