From 92ff079483ed0e8e4f1f2af7b75576905f4cf0ab Mon Sep 17 00:00:00 2001
From: mpw <x@mpw.sh>
Date: Fri, 15 Sep 2023 14:01:37 -0300
Subject: [PATCH] cargo fmt

---
 consumer/src/events.rs | 18 ++++++++----------
 1 file changed, 8 insertions(+), 10 deletions(-)

diff --git a/consumer/src/events.rs b/consumer/src/events.rs
index 0426faa..22043ce 100644
--- a/consumer/src/events.rs
+++ b/consumer/src/events.rs
@@ -904,13 +904,12 @@ impl Processor {
             CompressionLeaf::create(conn, compression_leaf).await?;
             let elapsed = i64::try_from(start.elapsed().as_millis()).unwrap_or(0);
 
-            self.metrics.rpc_tx_assembly_duration_ms_bucket.record(
-                elapsed,
-                &[
+            self.metrics
+                .rpc_tx_assembly_duration_ms_bucket
+                .record(elapsed, &[
                     KeyValue::new("blockchain", "Solana"),
                     KeyValue::new("compressed", "true"),
-                ],
-            );
+                ]);
 
             return Ok(tx.into());
         }
@@ -933,13 +932,12 @@ impl Processor {
         CollectionMint::create(conn, collection_mint).await?;
         let elapsed = i64::try_from(start.elapsed().as_millis()).unwrap_or(0);
 
-        self.metrics.rpc_tx_assembly_duration_ms_bucket.record(
-            elapsed,
-            &[
+        self.metrics
+            .rpc_tx_assembly_duration_ms_bucket
+            .record(elapsed, &[
                 KeyValue::new("blockchain", "Solana"),
                 KeyValue::new("compressed", "false"),
-            ],
-        );
+            ]);
 
         Ok(tx.into())
     }