From 1e3ccb663487e45314738edd0c58155cab8ae523 Mon Sep 17 00:00:00 2001
From: Gus Cairo <gus.cairo@apple.com>
Date: Tue, 21 Nov 2023 15:01:37 +0000
Subject: [PATCH] Formatting

---
 .../Transport/InProcessClientTransport.swift     |  4 ++--
 .../InProcessClientTransportTests.swift          | 16 +++++++++-------
 2 files changed, 11 insertions(+), 9 deletions(-)

diff --git a/Sources/GRPCCore/Transport/InProcessClientTransport.swift b/Sources/GRPCCore/Transport/InProcessClientTransport.swift
index b57ef0532..4107ffe59 100644
--- a/Sources/GRPCCore/Transport/InProcessClientTransport.swift
+++ b/Sources/GRPCCore/Transport/InProcessClientTransport.swift
@@ -236,7 +236,7 @@ public struct InProcessClientTransport: ClientTransport {
       inbound: request.stream,
       outbound: response.writer
     )
-    
+
     let waitForConnectionStream: AsyncStream<Void>? = self.state.withLockedValue { state in
       if case .unconnected(var unconnectedState) = state {
         let (stream, continuation) = AsyncStream<Void>.makeStream()
@@ -246,7 +246,7 @@ public struct InProcessClientTransport: ClientTransport {
       }
       return nil
     }
-    
+
     if let waitForConnectionStream {
       for await _ in waitForConnectionStream {
         // This loop will exit either when the task is cancelled or when the
diff --git a/Tests/GRPCCoreTests/Transport/InProcessClientTransportTests.swift b/Tests/GRPCCoreTests/Transport/InProcessClientTransportTests.swift
index 138dc655d..a438decec 100644
--- a/Tests/GRPCCoreTests/Transport/InProcessClientTransportTests.swift
+++ b/Tests/GRPCCoreTests/Transport/InProcessClientTransportTests.swift
@@ -20,7 +20,7 @@ import XCTest
 
 final class InProcessClientTransportTests: XCTestCase {
   struct FailTest: Error {}
-  
+
   func testConnectWhenConnected() async {
     let client = makeClient()
 
@@ -78,14 +78,14 @@ final class InProcessClientTransportTests: XCTestCase {
 
   func testCloseWhenUnconnected() {
     let client = makeClient()
-    
+
     XCTAssertNoThrow(client.close())
   }
 
   func testCloseWhenClosed() {
     let client = makeClient()
     client.close()
-    
+
     XCTAssertNoThrow(client.close())
   }
 
@@ -155,7 +155,7 @@ final class InProcessClientTransportTests: XCTestCase {
           try await stream.outbound.write(.message([1]))
           stream.outbound.finish()
           let receivedMessages = try await stream.inbound.collect()
-          
+
           XCTAssertEqual(receivedMessages, [.message([42])])
         }
       }
@@ -210,7 +210,7 @@ final class InProcessClientTransportTests: XCTestCase {
     XCTAssertEqual(client.executionConfiguration(forMethod: firstDescriptor), overrideConfiguration)
     XCTAssertEqual(client.executionConfiguration(forMethod: secondDescriptor), defaultConfiguration)
   }
-  
+
   func makeClient(
     configuration: ClientRPCExecutionConfiguration? = nil,
     server: InProcessServerTransport = InProcessServerTransport()
@@ -222,10 +222,12 @@ final class InProcessClientTransportTests: XCTestCase {
       backoffMultiplier: 1.0,
       retryableStatusCodes: [.unavailable]
     )
-    
+
     return InProcessClientTransport(
       server: server,
-      executionConfigurations: .init(defaultConfiguration: configuration ?? .init(retryPolicy: defaultPolicy))
+      executionConfigurations: .init(
+        defaultConfiguration: configuration ?? .init(retryPolicy: defaultPolicy)
+      )
     )
   }
 }