Skip to content

Commit 0ea7522

Browse files
author
Johannes Weiss
committed
give generic parameters nice names
1 parent 244aea6 commit 0ea7522

File tree

2 files changed

+22
-14
lines changed

2 files changed

+22
-14
lines changed

Sources/AsyncHTTPClient/HTTPClient.swift

+14-6
Original file line numberDiff line numberDiff line change
@@ -184,7 +184,9 @@ public class HTTPClient {
184184
/// - request: HTTP request to execute.
185185
/// - delegate: Delegate to process response parts.
186186
/// - deadline: Point in time by which the request must complete.
187-
public func execute<T: HTTPClientResponseDelegate>(request: Request, delegate: T, deadline: NIODeadline? = nil) -> Task<T.Response> {
187+
public func execute<Delegate: HTTPClientResponseDelegate>(request: Request,
188+
delegate: Delegate,
189+
deadline: NIODeadline? = nil) -> Task<Delegate.Response> {
188190
let eventLoop = self.eventLoopGroup.next()
189191
return self.execute(request: request, delegate: delegate, eventLoop: eventLoop, deadline: deadline)
190192
}
@@ -196,7 +198,10 @@ public class HTTPClient {
196198
/// - delegate: Delegate to process response parts.
197199
/// - eventLoop: NIO Event Loop preference.
198200
/// - deadline: Point in time by which the request must complete.
199-
public func execute<T: HTTPClientResponseDelegate>(request: Request, delegate: T, eventLoop: EventLoopPreference, deadline: NIODeadline? = nil) -> Task<T.Response> {
201+
public func execute<Delegate: HTTPClientResponseDelegate>(request: Request,
202+
delegate: Delegate,
203+
eventLoop: EventLoopPreference,
204+
deadline: NIODeadline? = nil) -> Task<Delegate.Response> {
200205
switch eventLoop.preference {
201206
case .indifferent:
202207
return self.execute(request: request, delegate: delegate, eventLoop: self.eventLoopGroup.next(), deadline: deadline)
@@ -206,17 +211,20 @@ public class HTTPClient {
206211
}
207212
}
208213

209-
private func execute<T: HTTPClientResponseDelegate>(request: Request, delegate: T, eventLoop: EventLoop, deadline: NIODeadline? = nil) -> Task<T.Response> {
210-
let redirectHandler: RedirectHandler<T.Response>?
214+
private func execute<Delegate: HTTPClientResponseDelegate>(request: Request,
215+
delegate: Delegate,
216+
eventLoop: EventLoop,
217+
deadline: NIODeadline? = nil) -> Task<Delegate.Response> {
218+
let redirectHandler: RedirectHandler<Delegate.Response>?
211219
if self.configuration.followRedirects {
212-
redirectHandler = RedirectHandler<T.Response>(request: request) { newRequest in
220+
redirectHandler = RedirectHandler<Delegate.Response>(request: request) { newRequest in
213221
self.execute(request: newRequest, delegate: delegate, eventLoop: eventLoop, deadline: deadline)
214222
}
215223
} else {
216224
redirectHandler = nil
217225
}
218226

219-
let task = Task<T.Response>(eventLoop: eventLoop)
227+
let task = Task<Delegate.Response>(eventLoop: eventLoop)
220228

221229
var bootstrap = ClientBootstrap(group: eventLoop)
222230
.channelOption(ChannelOptions.socket(SocketOptionLevel(IPPROTO_TCP), TCP_NODELAY), value: 1)

Sources/AsyncHTTPClient/HTTPHandler.swift

+8-8
Original file line numberDiff line numberDiff line change
@@ -432,7 +432,7 @@ extension HTTPClient {
432432

433433
internal struct TaskCancelEvent {}
434434

435-
internal class TaskHandler<T: HTTPClientResponseDelegate>: ChannelInboundHandler, ChannelOutboundHandler {
435+
internal class TaskHandler<Delegate: HTTPClientResponseDelegate>: ChannelInboundHandler, ChannelOutboundHandler {
436436
typealias OutboundIn = HTTPClient.Request
437437
typealias InboundIn = HTTPClientResponsePart
438438
typealias OutboundOut = HTTPClientRequestPart
@@ -446,16 +446,16 @@ internal class TaskHandler<T: HTTPClientResponseDelegate>: ChannelInboundHandler
446446
case end
447447
}
448448

449-
let task: HTTPClient.Task<T.Response>
450-
let delegate: T
451-
let redirectHandler: RedirectHandler<T.Response>?
449+
let task: HTTPClient.Task<Delegate.Response>
450+
let delegate: Delegate
451+
let redirectHandler: RedirectHandler<Delegate.Response>?
452452
let ignoreUncleanSSLShutdown: Bool
453453

454454
var state: State = .idle
455455
var pendingRead = false
456456
var mayRead = true
457457

458-
init(task: HTTPClient.Task<T.Response>, delegate: T, redirectHandler: RedirectHandler<T.Response>?, ignoreUncleanSSLShutdown: Bool) {
458+
init(task: HTTPClient.Task<Delegate.Response>, delegate: Delegate, redirectHandler: RedirectHandler<Delegate.Response>?, ignoreUncleanSSLShutdown: Bool) {
459459
self.task = task
460460
self.delegate = delegate
461461
self.redirectHandler = redirectHandler
@@ -650,9 +650,9 @@ internal class TaskHandler<T: HTTPClientResponseDelegate>: ChannelInboundHandler
650650
}
651651
}
652652

653-
internal struct RedirectHandler<T> {
653+
internal struct RedirectHandler<Response> {
654654
let request: HTTPClient.Request
655-
let execute: (HTTPClient.Request) -> HTTPClient.Task<T>
655+
let execute: (HTTPClient.Request) -> HTTPClient.Task<Response>
656656

657657
func redirectTarget(status: HTTPResponseStatus, headers: HTTPHeaders) -> URL? {
658658
switch status {
@@ -681,7 +681,7 @@ internal struct RedirectHandler<T> {
681681
return url.absoluteURL
682682
}
683683

684-
func redirect(status: HTTPResponseStatus, to redirectURL: URL, promise: EventLoopPromise<T>) {
684+
func redirect(status: HTTPResponseStatus, to redirectURL: URL, promise: EventLoopPromise<Response>) {
685685
let originalRequest = self.request
686686

687687
var convertToGet = false

0 commit comments

Comments
 (0)