refactor: remove unnecessary collect in GCP Pub/Sub sink

Author: psteinroe

src/sink/gcp_pubsub.rs

@@ -162,20 +162,16 @@ impl Sink for GcpPubsubSink {
                 .await;
 
         // Wait for all messages to be confirmed concurrently.
-        let futures: Vec<_> = awaiters
-            .into_iter()
-            .map(|awaiter| async move {
-                awaiter.get().await.map_err(|e| {
-                    etl::etl_error!(
-                        etl::error::ErrorKind::DestinationError,
-                        "Failed to publish message to Pub/Sub",
-                        e.to_string()
-                    )
-                })
+        try_join_all(awaiters.into_iter().map(|awaiter| async move {
+            awaiter.get().await.map_err(|e| {
+                etl::etl_error!(
+                    etl::error::ErrorKind::DestinationError,
+                    "Failed to publish message to Pub/Sub",
+                    e.to_string()
+                )
             })
-            .collect();
-
-        try_join_all(futures).await?;
+        }))
+        .await?;
 
         Ok(())
     }