Make sure that event loop of task is the same as event loop of channel (#55)

Author: t089

Sources/AsyncHTTPClient/HTTPClient.swift

@@ -123,7 +123,7 @@ public class HTTPClient{
 
 lettask=Task<T.Response>(eventLoop: eventLoop)
 
-varbootstrap=ClientBootstrap(group:self.eventLoopGroup)
+varbootstrap=ClientBootstrap(group:eventLoop)
 .channelOption(ChannelOptions.socket(SocketOptionLevel(IPPROTO_TCP), TCP_NODELAY), value:1)
 .channelInitializer{ channel in
 letencoder=HTTPRequestEncoder()

Sources/AsyncHTTPClient/HTTPHandler.swift

@@ -271,6 +271,7 @@ extension HTTPClient{
 }
 
 func setChannel(_ channel:Channel)->Channel{
+precondition(self.eventLoop === channel.eventLoop,"Channel must use same event loop as this task.")
 returnself.lock.withLock{
 self.channel = channel
 return channel

Tests/AsyncHTTPClientTests/HTTPClientTests+XCTest.swift

@@ -27,6 +27,7 @@ extension HTTPClientTests{
 return[
 ("testRequestURI", testRequestURI),
 ("testGet", testGet),
+("testGetWithSharedEventLoopGroup", testGetWithSharedEventLoopGroup),
 ("testPost", testPost),
 ("testGetHttps", testGetHttps),
 ("testPostHttps", testPostHttps),

Tests/AsyncHTTPClientTests/HTTPClientTests.swift

@@ -44,6 +44,25 @@ class HTTPClientTests: XCTestCase{
 letresponse=try httpClient.get(url:"http://localhost:\(httpBin.port)/get").wait()
 XCTAssertEqual(.ok, response.status)
 }
+
+func testGetWithSharedEventLoopGroup()throws{
+lethttpBin=HttpBin()
+letelg=MultiThreadedEventLoopGroup(numberOfThreads:8)
+lethttpClient=HTTPClient(eventLoopGroupProvider:.shared(elg))
+defer{
+try! elg.syncShutdownGracefully()
+ httpBin.shutdown()
+}
+
+letdelegate=TestHTTPDelegate()
+letrequest=tryHTTPClient.Request(url:"http://localhost:\(httpBin.port)/events/10/1")
+lettask= httpClient.execute(request: request, delegate: delegate)
+letexpectedEventLoop= task.eventLoop
+ task.futureResult.whenComplete{(_)in
+XCTAssertTrue(expectedEventLoop.inEventLoop)
+}
+try task.wait()
+}
 
 func testPost()throws{
 lethttpBin=HttpBin()