rename didReceivePart to didReceiveBodyPart (swift-server#84)

Author: artemredkin

README.md

@@ -136,7 +136,7 @@ class CountingDelegate: HTTPClientResponseDelegate{
 return task.eventLoop.makeSucceededFuture(())
  }
 
-funcdidReceivePart(task: HTTPClient.Task<Response>, _buffer: ByteBuffer) -> EventLoopFuture<Void>{
+funcdidReceiveBodyPart(task: HTTPClient.Task<Response>, _buffer: ByteBuffer) -> EventLoopFuture<Void>{
 // this is executed when we receive parts of the response body, could be called zero or more times
  count += buffer.readableBytes
 // in case backpressure is needed, all reads will be paused until returned future is resolved

Sources/AsyncHTTPClient/HTTPHandler.swift

@@ -230,7 +230,7 @@ internal class ResponseAccumulator: HTTPClientResponseDelegate{
 return task.eventLoop.makeSucceededFuture(())
 }
 
-funcdidReceivePart(task:HTTPClient.Task<Response>, _ part:ByteBuffer)->EventLoopFuture<Void>{
+funcdidReceiveBodyPart(task:HTTPClient.Task<Response>, _ part:ByteBuffer)->EventLoopFuture<Void>{
 switchself.state {
 case.idle:
 preconditionFailure("no head received before body")
@@ -319,7 +319,7 @@ public protocol HTTPClientResponseDelegate: AnyObject{
  /// - task: Current request context.
  /// - buffer: Received body `Part`.
  /// - returns: `EventLoopFuture` that will be used for backpressure.
-funcdidReceivePart(task:HTTPClient.Task<Response>, _ buffer:ByteBuffer)->EventLoopFuture<Void>
+funcdidReceiveBodyPart(task:HTTPClient.Task<Response>, _ buffer:ByteBuffer)->EventLoopFuture<Void>
 
  /// Called when error was thrown during request execution. Will be called zero or one time only. Request processing will be stopped after that.
  ///
@@ -345,7 +345,7 @@ extension HTTPClientResponseDelegate{
 
 publicfunc didReceiveHead(task:HTTPClient.Task<Response>, _:HTTPResponseHead)->EventLoopFuture<Void>{return task.eventLoop.makeSucceededFuture(())}
 
-publicfuncdidReceivePart(task:HTTPClient.Task<Response>, _:ByteBuffer)->EventLoopFuture<Void>{return task.eventLoop.makeSucceededFuture(())}
+publicfuncdidReceiveBodyPart(task:HTTPClient.Task<Response>, _:ByteBuffer)->EventLoopFuture<Void>{return task.eventLoop.makeSucceededFuture(())}
 
 publicfunc didReceiveError(task:HTTPClient.Task<Response>, _:Error){}
 }
@@ -550,7 +550,7 @@ internal class TaskHandler<T: HTTPClientResponseDelegate>: ChannelInboundHandler
 default:
 self.state =.body
 self.mayRead =false
-self.delegate.didReceivePart(task:self.task, body).whenComplete{ result in
+self.delegate.didReceiveBodyPart(task:self.task, body).whenComplete{ result in
 self.handleBackpressureResult(context: context, result: result)
 }
 }

Sources/AsyncHTTPClient/Utils.swift

@@ -24,7 +24,7 @@ public final class HTTPClientCopyingDelegate: HTTPClientResponseDelegate{
 self.chunkHandler = chunkHandler
 }
 
-publicfuncdidReceivePart(task:HTTPClient.Task<Void>, _ buffer:ByteBuffer)->EventLoopFuture<Void>{
+publicfuncdidReceiveBodyPart(task:HTTPClient.Task<Void>, _ buffer:ByteBuffer)->EventLoopFuture<Void>{
 returnself.chunkHandler(buffer)
 }
 

Tests/AsyncHTTPClientTests/HTTPClientInternalTests.swift

@@ -153,7 +153,7 @@ class HTTPClientInternalTests: XCTestCase{
 }
 }
 
-funcdidReceivePart(task:HTTPClient.Task<Response>, _ buffer:ByteBuffer)->EventLoopFuture<Void>{
+funcdidReceiveBodyPart(task:HTTPClient.Task<Response>, _ buffer:ByteBuffer)->EventLoopFuture<Void>{
 self.lock.withLockVoid{
 self._reads +=1
 }

Tests/AsyncHTTPClientTests/HTTPClientTestUtils.swift

@@ -36,7 +36,7 @@ class TestHTTPDelegate: HTTPClientResponseDelegate{
 return task.eventLoop.makeSucceededFuture(())
 }
 
-funcdidReceivePart(task:HTTPClient.Task<Response>, _ buffer:ByteBuffer)->EventLoopFuture<Void>{
+funcdidReceiveBodyPart(task:HTTPClient.Task<Response>, _ buffer:ByteBuffer)->EventLoopFuture<Void>{
 switchself.state {
 case.head(let head):
 self.state =.body(head, buffer)
@@ -58,7 +58,7 @@ class CountingDelegate: HTTPClientResponseDelegate{
 
 varcount=0
 
-funcdidReceivePart(task:HTTPClient.Task<Response>, _ buffer:ByteBuffer)->EventLoopFuture<Void>{
+funcdidReceiveBodyPart(task:HTTPClient.Task<Response>, _ buffer:ByteBuffer)->EventLoopFuture<Void>{
 letstr= buffer.getString(at:0, length: buffer.readableBytes)
 if str?.starts(with:"id:")??false{
 self.count +=1