review fix

Author: artemredkin

Tests/AsyncHTTPClientTests/HTTPClientInternalTests+XCTest.swift

@@ -41,6 +41,7 @@ extension HTTPClientInternalTests {
             ("testUncleanCloseThrows", testUncleanCloseThrows),
             ("testUploadStreamingIsCalledOnTaskEL", testUploadStreamingIsCalledOnTaskEL),
             ("testWeCanActuallyExactlySetTheEventLoops", testWeCanActuallyExactlySetTheEventLoops),
+            ("testTaskPromiseBoundToEL", testTaskPromiseBoundToEL),
         ]
     }
 }

Tests/AsyncHTTPClientTests/HTTPClientInternalTests.swift

@@ -891,4 +891,16 @@ class HTTPClientInternalTests: XCTestCase {
         XCTAssert(el1 === response.eventLoop)
         XCTAssertNoThrow(try response.wait())
     }
+
+    func testTaskPromiseBoundToEL() throws {
+        let elg = getDefaultEventLoopGroup(numberOfThreads: 2)
+        let el = elg.next()
+
+        defer {
+            XCTAssertNoThrow(try elg.syncShutdownGracefully())
+        }
+
+        let task: Task<HTTPClient.Response> = .init(eventLoop: el, logger: HTTPClient.loggingDisabled)
+        XCTAssertTrue(task.futureResult.eventLoop === el)
+    }
 }

Tests/AsyncHTTPClientTests/HTTPClientTests+XCTest.swift

@@ -109,7 +109,6 @@ extension HTTPClientTests {
             ("testNothingIsLoggedAtInfoOrHigher", testNothingIsLoggedAtInfoOrHigher),
             ("testAllMethodsLog", testAllMethodsLog),
             ("testClosingIdleConnectionsInPoolLogsInTheBackground", testClosingIdleConnectionsInPoolLogsInTheBackground),
-            ("testTaskPromiseBoundToEL", testTaskPromiseBoundToEL),
         ]
     }
 }

Tests/AsyncHTTPClientTests/HTTPClientTests.swift

@@ -2005,22 +2005,4 @@ class HTTPClientTests: XCTestCase {
 
         self.defaultClient = nil // so it doesn't get shut down again.
     }
-
-    func testTaskPromiseBoundToEL() throws {
-        let elg = getDefaultEventLoopGroup(numberOfThreads: 2)
-        let el = elg.next()
-
-        let client = HTTPClient(eventLoopGroupProvider: .shared(elg))
-
-        defer {
-            XCTAssertNoThrow(try client.syncShutdown())
-            XCTAssertNoThrow(try elg.syncShutdownGracefully())
-        }
-
-        let request = try HTTPClient.Request(url: self.defaultHTTPBinURLPrefix + "/get")
-        let delegate = ResponseAccumulator(request: request)
-        let task = client.execute(request: request, delegate: delegate, eventLoop: .delegate(on: el))
-        XCTAssertTrue(task.futureResult.eventLoop === el)
-        XCTAssertNoThrow(try task.wait())
-    }
 }