style: format GCP Pub/Sub sink

Author: psteinroe

src/sink/gcp_pubsub.rs

@@ -157,12 +157,9 @@ impl Sink for GcpPubsubSink {
 
         // Publish all messages concurrently and collect awaiters.
         // The publisher batches messages internally (default: 10ms, 100 messages, or 1MiB).
-        let awaiters = futures::future::join_all(
-            messages
-                .into_iter()
-                .map(|msg| self.publisher.publish(msg)),
-        )
-        .await;
+        let awaiters =
+            futures::future::join_all(messages.into_iter().map(|msg| self.publisher.publish(msg)))
+                .await;
 
         // Wait for all messages to be confirmed concurrently.
         let futures: Vec<_> = awaiters