Skip to content

Commit b1c0c3c

Browse files
authored
replace EventLoopGroup.next() with .any() (#526)
1 parent 5db7719 commit b1c0c3c

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

Sources/AsyncHTTPClient/HTTPClient.swift

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -220,7 +220,7 @@ public class HTTPClient {
220220
return
221221
}
222222

223-
let promise = self.eventLoopGroup.next().makePromise(of: Bool.self)
223+
let promise = self.eventLoopGroup.any().makePromise(of: Bool.self)
224224
self.poolManager.shutdown(promise: promise)
225225
promise.futureResult.whenComplete { result in
226226
switch result {
@@ -358,7 +358,7 @@ public class HTTPClient {
358358
let request = try Request(url: url, method: method, body: body)
359359
return self.execute(request: request, deadline: deadline, logger: logger ?? HTTPClient.loggingDisabled)
360360
} catch {
361-
return self.eventLoopGroup.next().makeFailedFuture(error)
361+
return self.eventLoopGroup.any().makeFailedFuture(error)
362362
}
363363
}
364364

@@ -379,7 +379,7 @@ public class HTTPClient {
379379
let request = try Request(url: url, method: method, body: body)
380380
return self.execute(request: request, deadline: deadline, logger: logger ?? HTTPClient.loggingDisabled)
381381
} catch {
382-
return self.eventLoopGroup.next().makeFailedFuture(error)
382+
return self.eventLoopGroup.any().makeFailedFuture(error)
383383
}
384384
}
385385

@@ -400,7 +400,7 @@ public class HTTPClient {
400400
let request = try Request(url: url, method: method, body: body)
401401
return self.execute(request: request, deadline: deadline, logger: logger ?? HTTPClient.loggingDisabled)
402402
} catch {
403-
return self.eventLoopGroup.next().makeFailedFuture(error)
403+
return self.eventLoopGroup.any().makeFailedFuture(error)
404404
}
405405
}
406406

0 commit comments

Comments
 (0)