File tree Expand file tree Collapse file tree 2 files changed +7
-7
lines changed
Tests/SocketForwarderTests Expand file tree Collapse file tree 2 files changed +7
-7
lines changed Original file line number Diff line number Diff line change @@ -82,10 +82,10 @@ extension ConnectHandler {
8282 . assumeIsolatedUnsafeUnchecked ( )
8383 . whenComplete { result in
8484 guard !self . removed else {
85- if case . success( let channel) = result {
86- channel. close ( promise: nil )
87- }
88- return
85+ if case . success( let channel) = result {
86+ channel. close ( promise: nil )
87+ }
88+ return
8989 }
9090
9191 switch result {
Original file line number Diff line number Diff line change 1616
1717import NIO
1818import Testing
19+
1920@testable import SocketForwarder
2021
2122struct ConnectHandlerRaceTest {
@@ -24,7 +25,7 @@ struct ConnectHandlerRaceTest {
2425 @Test
2526 func testRapidConnectDisconnect( ) async throws {
2627 let requestCount = 500
27-
28+
2829 let serverAddress = try SocketAddress ( ipAddress: " 127.0.0.1 " , port: 0 )
2930 let server = TCPEchoServer ( serverAddress: serverAddress, eventLoopGroup: eventLoopGroup)
3031 let serverChannel = try await server. run ( ) . get ( )
@@ -46,7 +47,7 @@ struct ConnectHandlerRaceTest {
4647 let channel = try await ClientBootstrap ( group: self . eventLoopGroup)
4748 . connect ( to: actualProxyAddress)
4849 . get ( )
49-
50+
5051 try await channel. close ( )
5152 } catch {
5253 // Going to ignore connection errors as we are intentionally stressing it
@@ -63,4 +64,3 @@ struct ConnectHandlerRaceTest {
6364 try await forwarderResult. wait ( )
6465 }
6566}
66-
You can’t perform that action at this time.
0 commit comments