fmt

Signed-off-by: Keran Yang <yangkr920208@gmail.com>
numaproj · Oct 1, 2024 · 63accfc · 63accfc
1 parent 767af03
commit 63accfc
Showing 1 changed file with 7 additions and 7 deletions.
diff --git a/src/sourcetransform.rs b/src/sourcetransform.rs
@@ -662,9 +662,9 @@ mod tests {
             Duration::from_secs(2),
             client.source_transform_fn(ReceiverStream::new(rx)),
         )
-            .await
-            .map_err(|_| "timeout while getting stream for source_transform_fn")??
-            .into_inner();
+        .await
+        .map_err(|_| "timeout while getting stream for source_transform_fn")??
+        .into_inner();
 
         let handshake_resp = stream.message().await?.unwrap();
         assert!(
@@ -767,9 +767,9 @@ mod tests {
             Duration::from_secs(2),
             client.source_transform_fn(ReceiverStream::new(rx)),
         )
-            .await
-            .map_err(|_| "timeout while getting stream for source_transform_fn")??
-            .into_inner();
+        .await
+        .map_err(|_| "timeout while getting stream for source_transform_fn")??
+        .into_inner();
 
         let handshake_resp = stream.message().await?.unwrap();
         assert!(
@@ -800,4 +800,4 @@ mod tests {
         assert!(task.is_finished(), "gRPC server is still running");
         Ok(())
     }
-}
+}