Re-format code

Author: glbrntt

Sources/Examples/Echo/Implementation/HPACKHeaders+Prettify.swift

@@ -16,7 +16,8 @@
 import NIOHPACK
 
 func prettify(_ headers: HPACKHeaders) -> String {
-  return "[" + headers.map { name, value, _ in
-    "'\(name)': '\(value)'"
-  }.joined(separator: ", ") + "]"
+  return "["
+    + headers.map { name, value, _ in
+      "'\(name)': '\(value)'"
+    }.joined(separator: ", ") + "]"
 }

Sources/Examples/Echo/Implementation/Interceptors.swift

@@ -107,7 +107,8 @@ public final class ExampleClientInterceptorFactory: Echo_EchoClientInterceptorFa
 
   // Returns an array of interceptors to use for the 'Collect' RPC.
   public func makeCollectInterceptors()
-    -> [ClientInterceptor<Echo_EchoRequest, Echo_EchoResponse>] {
+    -> [ClientInterceptor<Echo_EchoRequest, Echo_EchoResponse>]
+  {
     return [LoggingEchoClientInterceptor()]
   }
 

Sources/Examples/Echo/Runtime/Echo.swift

@@ -20,6 +20,7 @@ import GRPC
 import GRPCSampleData
 import NIOCore
 import NIOPosix
+
 #if canImport(NIOSSL)
 import NIOSSL
 #endif
@@ -136,7 +137,7 @@ func startEchoServer(group: EventLoopGroup, port: Int, useTLS: Bool) async throw
     print("starting secure server")
     #else
     fatalError("'useTLS: true' passed to \(#function) but NIOSSL is not available")
-    #endif // canImport(NIOSSL)
+    #endif  // canImport(NIOSSL)
   } else {
     print("starting insecure server")
     builder = Server.insecure(group: group)
@@ -180,7 +181,7 @@ func makeClient(
       .withTLS(trustRoots: .certificates([caCert.certificate]))
     #else
     fatalError("'useTLS: true' passed to \(#function) but NIOSSL is not available")
-    #endif // canImport(NIOSSL)
+    #endif  // canImport(NIOSSL)
   } else {
     builder = ClientConnection.insecure(group: group)
   }

Sources/Examples/PacketCapture/PacketCapture.swift

@@ -56,9 +56,11 @@ struct PCAP: AsyncParsableCommand {
         // used TLS we would likely want to place the handler in a different position in the
         // pipeline so that the captured packets in the trace would not be encrypted.
         let writePCAPHandler = NIOWritePCAPHandler(mode: .client, fileSink: fileSink.write(buffer:))
-        return channel.eventLoop.makeCompletedFuture(Result {
-          try channel.pipeline.syncOperations.addHandler(writePCAPHandler, position: .first)
-        })
+        return channel.eventLoop.makeCompletedFuture(
+          Result {
+            try channel.pipeline.syncOperations.addHandler(writePCAPHandler, position: .first)
+          }
+        )
       }
     }
 

Sources/Examples/RouteGuide/Client/RouteGuideClient.swift

@@ -23,8 +23,8 @@ import RouteGuideModel
 /// Loads the features from `route_guide_db.json`, assumed to be in the directory above this file.
 func loadFeatures() throws -> [Routeguide_Feature] {
   let url = URL(fileURLWithPath: #filePath)
-    .deletingLastPathComponent() // main.swift
-    .deletingLastPathComponent() // Client/
+    .deletingLastPathComponent()  // main.swift
+    .deletingLastPathComponent()  // Client/
     .appendingPathComponent("route_guide_db.json")
 
   let data = try Data(contentsOf: url)
@@ -146,8 +146,8 @@ extension RouteGuideExample {
       let summary = try await recordRoute.response
 
       print(
-        "Finished trip with \(summary.pointCount) points. Passed \(summary.featureCount) features. " +
-          "Travelled \(summary.distance) meters. It took \(summary.elapsedTime) seconds."
+        "Finished trip with \(summary.pointCount) points. Passed \(summary.featureCount) features. "
+          + "Travelled \(summary.distance) meters. It took \(summary.elapsedTime) seconds."
       )
     } catch {
       print("RecordRoute Failed: \(error)")

Sources/Examples/RouteGuide/Server/RouteGuideProvider.swift

@@ -148,7 +148,8 @@ extension Routeguide_Point {
     let deltaLat = lat2 - lat1
     let deltaLon = lon2 - lon1
 
-    let a = sin(deltaLat / 2) * sin(deltaLat / 2)
+    let a =
+      sin(deltaLat / 2) * sin(deltaLat / 2)
       + cos(lat1) * cos(lat2) * sin(deltaLon / 2) * sin(deltaLon / 2)
     let c = 2 * atan2(sqrt(a), sqrt(1 - a))
 

Sources/Examples/RouteGuide/Server/RouteGuideServer.swift

@@ -14,18 +14,19 @@
  * limitations under the License.
  */
 import ArgumentParser
-import struct Foundation.Data
-import struct Foundation.URL
 import GRPC
 import NIOCore
 import NIOPosix
 import RouteGuideModel
 
+import struct Foundation.Data
+import struct Foundation.URL
+
 /// Loads the features from `route_guide_db.json`, assumed to be in the directory above this file.
 func loadFeatures() throws -> [Routeguide_Feature] {
   let url = URL(fileURLWithPath: #filePath)
-    .deletingLastPathComponent() // main.swift
-    .deletingLastPathComponent() // Server/
+    .deletingLastPathComponent()  // main.swift
+    .deletingLastPathComponent()  // Server/
     .appendingPathComponent("route_guide_db.json")
 
   let data = try Data(contentsOf: url)

Sources/GRPC/AsyncAwaitSupport/Call+AsyncRequestStreamWriter.swift

@@ -22,11 +22,13 @@ extension Call where Request: Sendable, Response: Sendable {
     GRPCAsyncWriterSinkDelegate<(Request, Compression)>
   >
   internal func makeRequestStreamWriter()
-    -> (GRPCAsyncRequestStreamWriter<Request>, AsyncWriter.Sink) {
+    -> (GRPCAsyncRequestStreamWriter<Request>, AsyncWriter.Sink)
+  {
     let delegate = GRPCAsyncWriterSinkDelegate<(Request, Compression)>(
       didYield: { requests in
         for (request, compression) in requests {
-          let compress = compression
+          let compress =
+            compression
             .isEnabled(callDefault: self.options.messageEncoding.enabledForRequests)
 
           // TODO: be smarter about inserting flushes.

Sources/GRPC/AsyncAwaitSupport/GRPCAsyncBidirectionalStreamingCall.swift

@@ -21,12 +21,13 @@ import NIOHPACK
 public struct GRPCAsyncBidirectionalStreamingCall<Request: Sendable, Response: Sendable>: Sendable {
   private let call: Call<Request, Response>
   private let responseParts: StreamingResponseParts<Response>
-  private let responseSource: NIOThrowingAsyncSequenceProducer<
-    Response,
-    Error,
-    NIOAsyncSequenceProducerBackPressureStrategies.HighLowWatermark,
-    GRPCAsyncSequenceProducerDelegate
-  >.Source
+  private let responseSource:
+    NIOThrowingAsyncSequenceProducer<
+      Response,
+      Error,
+      NIOAsyncSequenceProducerBackPressureStrategies.HighLowWatermark,
+      GRPCAsyncSequenceProducerDelegate
+    >.Source
   private let requestSink: AsyncSink<(Request, Compression)>
 
   /// A request stream writer for sending messages to the server.

Sources/GRPC/AsyncAwaitSupport/GRPCAsyncServerHandler.swift

@@ -232,19 +232,23 @@ internal final class AsyncServerHandler<
   internal private(set) var handlerStateMachine: ServerHandlerStateMachine
   /// A bag of components used by the user handler.
   @usableFromInline
-  internal private(set) var handlerComponents: Optional<ServerHandlerComponents<
-    Request,
-    Response,
-    GRPCAsyncWriterSinkDelegate<(Response, Compression)>
-  >>
+  internal private(set) var handlerComponents:
+    Optional<
+      ServerHandlerComponents<
+        Request,
+        Response,
+        GRPCAsyncWriterSinkDelegate<(Response, Compression)>
+      >
+    >
 
   /// The user provided function to execute.
   @usableFromInline
-  internal let userHandler: @Sendable (
-    GRPCAsyncRequestStream<Request>,
-    GRPCAsyncResponseStreamWriter<Response>,
-    GRPCAsyncServerCallContext
-  ) async throws -> Void
+  internal let userHandler:
+    @Sendable (
+      GRPCAsyncRequestStream<Request>,
+      GRPCAsyncResponseStreamWriter<Response>,
+      GRPCAsyncServerCallContext
+    ) async throws -> Void
 
   @usableFromInline
   internal typealias AsyncSequenceProducer = NIOThrowingAsyncSequenceProducer<
@@ -415,7 +419,7 @@ internal final class AsyncServerHandler<
   internal func receiveInterceptedMetadata(_ headers: HPACKHeaders) {
     switch self.interceptorStateMachine.interceptedRequestMetadata() {
     case .forward:
-      () // continue
+      ()  // continue
     case .cancel:
       return self.cancel(error: nil)
     case .drop: