remove unused degate and make other one public+rename (#61)

Author: artemredkin

Sources/AsyncHTTPClient/Utils.swift

@@ -15,45 +15,7 @@
 import NIO
 import NIOHTTP1
 
-public class HandlingHTTPResponseDelegate<T>: HTTPClientResponseDelegate {
-    struct EmptyEndHandlerError: Error {}
-
-    public typealias Result = T
-
-    var handleHead: ((HTTPResponseHead) -> Void)?
-    var handleBody: ((ByteBuffer) -> Void)?
-    var handleError: ((Error) -> Void)?
-    var handleEnd: (() throws -> T)?
-
-    public func didReceiveHead(task: HTTPClient.Task<T>, _ head: HTTPResponseHead) -> EventLoopFuture<Void> {
-        if let handler = handleHead {
-            handler(head)
-        }
-        return task.eventLoop.makeSucceededFuture(())
-    }
-
-    public func didReceivePart(task: HTTPClient.Task<T>, _ buffer: ByteBuffer) -> EventLoopFuture<Void> {
-        if let handler = handleBody {
-            handler(buffer)
-        }
-        return task.eventLoop.makeSucceededFuture(())
-    }
-
-    public func didReceiveError(task: HTTPClient.Task<T>, _ error: Error) {
-        if let handler = handleError {
-            handler(error)
-        }
-    }
-
-    public func didFinishRequest(task: HTTPClient.Task<T>) throws -> T {
-        if let handler = handleEnd {
-            return try handler()
-        }
-        throw EmptyEndHandlerError()
-    }
-}
-
-final class CopyingDelegate: HTTPClientResponseDelegate {
+public final class HTTPClientCopyingDelegate: HTTPClientResponseDelegate {
     public typealias Response = Void
 
     let chunkHandler: (ByteBuffer) -> EventLoopFuture<Void>
@@ -62,11 +24,11 @@ final class CopyingDelegate: HTTPClientResponseDelegate {
         self.chunkHandler = chunkHandler
     }
 
-    func didReceivePart(task: HTTPClient.Task<Void>, _ buffer: ByteBuffer) -> EventLoopFuture<Void> {
+    public func didReceivePart(task: HTTPClient.Task<Void>, _ buffer: ByteBuffer) -> EventLoopFuture<Void> {
         return self.chunkHandler(buffer)
     }
 
-    func didFinishRequest(task: HTTPClient.Task<Void>) throws {
+    public func didFinishRequest(task: HTTPClient.Task<Void>) throws {
         return ()
     }
 }

Tests/AsyncHTTPClientTests/HTTPClientInternalTests.swift

@@ -86,7 +86,7 @@ class HTTPClientInternalTests: XCTestCase {
                 var request = try Request(url: "http://localhost:\(httpBin.port)/events/10/1")
                 request.headers.add(name: "Accept", value: "text/event-stream")
 
-                let delegate = CopyingDelegate { part in
+                let delegate = HTTPClientCopyingDelegate { part in
                     writer.write(.byteBuffer(part))
                 }
                 return httpClient.execute(request: request, delegate: delegate).futureResult
@@ -122,7 +122,7 @@ class HTTPClientInternalTests: XCTestCase {
                 var request = try Request(url: "http://localhost:\(httpBin.port)/events/10/1")
                 request.headers.add(name: "Accept", value: "text/event-stream")
 
-                let delegate = CopyingDelegate { _ in
+                let delegate = HTTPClientCopyingDelegate { _ in
                     httpClient.eventLoopGroup.next().makeFailedFuture(HTTPClientError.invalidProxyResponse)
                 }
                 return httpClient.execute(request: request, delegate: delegate).futureResult