Skip to content

Commit 1b31c5a

Browse files
authored
give generic parameters nice names (#99)
1 parent 47de4bb commit 1b31c5a

File tree

2 files changed

+22
-14
lines changed

2 files changed

+22
-14
lines changed

Sources/AsyncHTTPClient/HTTPClient.swift

Lines changed: 14 additions & 6 deletions
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

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -467,7 +467,7 @@ extension HTTPClient {
467467

468468
internal struct TaskCancelEvent {}
469469

470-
internal class TaskHandler<T: HTTPClientResponseDelegate>: ChannelInboundHandler, ChannelOutboundHandler {
470+
internal class TaskHandler<Delegate: HTTPClientResponseDelegate>: ChannelInboundHandler, ChannelOutboundHandler {
471471
typealias OutboundIn = HTTPClient.Request
472472
typealias InboundIn = HTTPClientResponsePart
473473
typealias OutboundOut = HTTPClientRequestPart
@@ -481,16 +481,16 @@ internal class TaskHandler<T: HTTPClientResponseDelegate>: ChannelInboundHandler
481481
case end
482482
}
483483

484-
let task: HTTPClient.Task<T.Response>
485-
let delegate: T
486-
let redirectHandler: RedirectHandler<T.Response>?
484+
let task: HTTPClient.Task<Delegate.Response>
485+
let delegate: Delegate
486+
let redirectHandler: RedirectHandler<Delegate.Response>?
487487
let ignoreUncleanSSLShutdown: Bool
488488

489489
var state: State = .idle
490490
var pendingRead = false
491491
var mayRead = true
492492

493-
init(task: HTTPClient.Task<T.Response>, delegate: T, redirectHandler: RedirectHandler<T.Response>?, ignoreUncleanSSLShutdown: Bool) {
493+
init(task: HTTPClient.Task<Delegate.Response>, delegate: Delegate, redirectHandler: RedirectHandler<Delegate.Response>?, ignoreUncleanSSLShutdown: Bool) {
494494
self.task = task
495495
self.delegate = delegate
496496
self.redirectHandler = redirectHandler
@@ -685,9 +685,9 @@ internal class TaskHandler<T: HTTPClientResponseDelegate>: ChannelInboundHandler
685685
}
686686
}
687687

688-
internal struct RedirectHandler<T> {
688+
internal struct RedirectHandler<ResponseType> {
689689
let request: HTTPClient.Request
690-
let execute: (HTTPClient.Request) -> HTTPClient.Task<T>
690+
let execute: (HTTPClient.Request) -> HTTPClient.Task<ResponseType>
691691

692692
func redirectTarget(status: HTTPResponseStatus, headers: HTTPHeaders) -> URL? {
693693
switch status {
@@ -716,7 +716,7 @@ internal struct RedirectHandler<T> {
716716
return url.absoluteURL
717717
}
718718

719-
func redirect(status: HTTPResponseStatus, to redirectURL: URL, promise: EventLoopPromise<T>) {
719+
func redirect(status: HTTPResponseStatus, to redirectURL: URL, promise: EventLoopPromise<ResponseType>) {
720720
let originalRequest = self.request
721721

722722
var convertToGet = false

0 commit comments

Comments
 (0)