From 59b12eb0223a47c71b35fa66724bc010d5ad0972 Mon Sep 17 00:00:00 2001
From: Vigith Maurice <vigith@gmail.com>
Date: Thu, 26 Sep 2024 19:30:13 -0700
Subject: [PATCH] chore: cargo fmt

Signed-off-by: Vigith Maurice <vigith@gmail.com>
---
 src/sink.rs | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/src/sink.rs b/src/sink.rs
index ca8e434..160a374 100644
--- a/src/sink.rs
+++ b/src/sink.rs
@@ -231,7 +231,6 @@ where
         mut sink_stream: Streaming<sink_pb::SinkRequest>,
         grpc_resp_tx: mpsc::Sender<Result<SinkResponse, Status>>,
     ) -> Result<(), Error> {
-
         // loop until the global stream has been shutdown.
         loop {
             // for every batch, we need to read from the stream. The end-of-batch is
@@ -241,7 +240,7 @@ where
                 &mut sink_stream,
                 grpc_resp_tx.clone(),
             )
-                .await?;
+            .await?;
 
             if stream_ended {
                 // shutting down, hence exiting the loop