chore: run formatter

juspay · Nov 22, 2023 · 9a7ee49 · 9a7ee49
1 parent 48f6a1d
commit 9a7ee49
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 9 deletions.
diff --git a/crates/drainer/src/lib.rs b/crates/drainer/src/lib.rs
@@ -64,11 +64,9 @@ pub async fn start_drainer(
                     ));
                     jobs_picked += 1;
                 }
-                (stream_index, jobs_picked) = utils::increment_stream_index(
-                    (stream_index, jobs_picked),
-                    number_of_streams,
-                )
-                .await;
+                (stream_index, jobs_picked) =
+                    utils::increment_stream_index((stream_index, jobs_picked), number_of_streams)
+                        .await;
                 loop_interval.tick().await;
             }
             Ok(()) | Err(mpsc::error::TryRecvError::Disconnected) => {

diff --git a/crates/drainer/src/utils.rs b/crates/drainer/src/utils.rs
@@ -127,10 +127,7 @@ pub fn parse_stream_entries<'a>(
 
 // Here the output is in the format (stream_index, jobs_picked),
 // similar to the first argument of the function
-pub async fn increment_stream_index(
-    (index, jobs_picked): (u8, u8),
-    total_streams: u8,
-) -> (u8, u8) {
+pub async fn increment_stream_index((index, jobs_picked): (u8, u8), total_streams: u8) -> (u8, u8) {
     if index == total_streams - 1 {
         match jobs_picked {
             0 => metrics::CYCLES_COMPLETED_UNSUCCESSFULLY.add(&metrics::CONTEXT, 1, &[]),