Closed
Description
This snippet:
func testErrorsAreSurfaced() {
let httpBin = HTTPBin()
let httpClient = HTTPClient(eventLoopGroupProvider: .shared(self.clientGroup))
defer {
XCTAssertNoThrow(try httpClient.syncShutdown())
XCTAssertNoThrow(try httpBin.shutdown())
}
let request = try! HTTPClient.Request(url: "http://localhost:\(httpBin.port)/get",
method: .POST,
body: .stream { streamWriter in
print("GOT STREAM")
return httpClient.eventLoopGroup.next().makeSucceededFuture(())
})
let runningRequest = httpClient.execute(request: request)
XCTAssertThrowsError(try runningRequest.wait()) { error in
print(error)
}
}
will just get stuck indefinitely.