fmt check fix

src/api/query.rs

@@ -352,7 +352,9 @@ where
     }
 
     client
-        .send(PgWireBackendMessage::CommandComplete(tag.with_rows(rows).into()))
+        .send(PgWireBackendMessage::CommandComplete(
+            tag.with_rows(rows).into(),
+        ))
         .await?;
 
     Ok(())

src/api/results.rs

@@ -142,7 +142,11 @@ pub struct QueryResponse<'a> {
 
 impl<'a> QueryResponse<'a> {
     /// Create `QueryResponse` from column schemas and stream of data row
-    pub fn new<S>(command_tag: &str, field_defs: Arc<Vec<FieldInfo>>, row_stream: S) -> QueryResponse<'a>
+    pub fn new<S>(
+        command_tag: &str,
+        field_defs: Arc<Vec<FieldInfo>>,
+        row_stream: S,
+    ) -> QueryResponse<'a>
     where
         S: Stream<Item = PgWireResult<DataRow>> + Send + Unpin + 'a,
     {

tests-integration/test-server/src/main.rs

@@ -141,7 +141,11 @@ impl ExtendedQueryHandler for DummyDatabase {
                 encoder.finish()
             });
 
-            Ok(Response::Query(QueryResponse::new("SELECT", schema, data_row_stream)))
+            Ok(Response::Query(QueryResponse::new(
+                "SELECT",
+                schema,
+                data_row_stream,
+            )))
         } else {
             Ok(Response::Execution(Tag::new("OK").with_rows(1)))
         }