Formatting

apple · Dec 13, 2024 · aa646a8 · aa646a8
1 parent cbc110b
commit aa646a8
Show file tree

Hide file tree

Showing 3 changed files with 24 additions and 6 deletions.
diff --git a/Sources/NIOAsyncAwaitDemo/AsyncChannelIO.swift b/Sources/NIOAsyncAwaitDemo/AsyncChannelIO.swift
@@ -25,7 +25,9 @@ struct AsyncChannelIO<Request, Response> {
 
     func start() async throws -> AsyncChannelIO<Request, Response> {
         try await channel.eventLoop.submit {
-            try channel.pipeline.syncOperations.addHandler(RequestResponseHandler<HTTPRequestHead, NIOHTTPClientResponseFull>())
+            try channel.pipeline.syncOperations.addHandler(
+                RequestResponseHandler<HTTPRequestHead, NIOHTTPClientResponseFull>()
+            )
         }.get()
         return self
     }

diff --git a/Tests/NIOPosixTests/RawSocketBootstrapTests.swift b/Tests/NIOPosixTests/RawSocketBootstrapTests.swift
@@ -49,7 +49,10 @@ final class RawSocketBootstrapTests: XCTestCase {
         let channel = try NIORawSocketBootstrap(group: elg)
             .channelInitializer { channel in
                 channel.eventLoop.makeCompletedFuture {
-                    try channel.pipeline.syncOperations.addHandler(DatagramReadRecorder<ByteBuffer>(), name: "ByteReadRecorder")
+                    try channel.pipeline.syncOperations.addHandler(
+                        DatagramReadRecorder<ByteBuffer>(),
+                        name: "ByteReadRecorder"
+                    )
                 }
             }
             .bind(host: "127.0.0.1", ipProtocol: .reservedForTesting).wait()
@@ -97,7 +100,10 @@ final class RawSocketBootstrapTests: XCTestCase {
         let readChannel = try NIORawSocketBootstrap(group: elg)
             .channelInitializer { channel in
                 channel.eventLoop.makeCompletedFuture {
-                    try channel.pipeline.syncOperations.addHandler(DatagramReadRecorder<ByteBuffer>(), name: "ByteReadRecorder")
+                    try channel.pipeline.syncOperations.addHandler(
+                        DatagramReadRecorder<ByteBuffer>(),
+                        name: "ByteReadRecorder"
+                    )
                 }
             }
             .bind(host: "127.0.0.1", ipProtocol: .reservedForTesting).wait()
@@ -106,7 +112,10 @@ final class RawSocketBootstrapTests: XCTestCase {
         let writeChannel = try NIORawSocketBootstrap(group: elg)
             .channelInitializer { channel in
                 channel.eventLoop.makeCompletedFuture {
-                    try channel.pipeline.syncOperations.addHandler(DatagramReadRecorder<ByteBuffer>(), name: "ByteReadRecorder")
+                    try channel.pipeline.syncOperations.addHandler(
+                        DatagramReadRecorder<ByteBuffer>(),
+                        name: "ByteReadRecorder"
+                    )
                 }
             }
             .bind(host: "127.0.0.1", ipProtocol: .reservedForTesting).wait()
@@ -155,7 +164,10 @@ final class RawSocketBootstrapTests: XCTestCase {
             .channelOption(.ipOption(.ip_hdrincl), value: 1)
             .channelInitializer { channel in
                 channel.eventLoop.makeCompletedFuture {
-                    try channel.pipeline.syncOperations.addHandler(DatagramReadRecorder<ByteBuffer>(), name: "ByteReadRecorder")
+                    try channel.pipeline.syncOperations.addHandler(
+                        DatagramReadRecorder<ByteBuffer>(),
+                        name: "ByteReadRecorder"
+                    )
                 }
             }
             .bind(host: "127.0.0.1", ipProtocol: .reservedForTesting).wait()

diff --git a/Tests/NIOPosixTests/UniversalBootstrapSupportTest.swift b/Tests/NIOPosixTests/UniversalBootstrapSupportTest.swift
@@ -84,7 +84,11 @@ class UniversalBootstrapSupportTest: XCTestCase {
                 let client = try NIOClientTCPBootstrap(ClientBootstrap(group: group), tls: DummyTLSProvider())
                     .channelInitializer { channel in
                         channel.eventLoop.makeCompletedFuture {
-                            try channel.pipeline.syncOperations.addHandlers(counter1, DropChannelReadsHandler(), counter2)
+                            try channel.pipeline.syncOperations.addHandlers(
+                                counter1,
+                                DropChannelReadsHandler(),
+                                counter2
+                            )
                         }
                     }
                     .channelOption(.autoRead, value: false)