@@ -65,35 +65,10 @@ private final class HTTPHandler: ChannelInboundHandler {
6565 public typealias InboundIn = HTTPServerRequestPart
6666 public typealias OutboundOut = HTTPServerResponsePart
6767
68- private enum State {
69- case idle
70- case waitingForRequestBody
71- case sendingResponse
72-
73- mutating func requestReceived( ) {
74- precondition ( self == . idle, " Invalid state for request received: \( self ) " )
75- self = . waitingForRequestBody
76- }
77-
78- mutating func requestComplete( ) {
79- precondition (
80- self == . waitingForRequestBody,
81- " Invalid state for request complete: \( self ) "
82- )
83- self = . sendingResponse
84- }
85-
86- mutating func responseComplete( ) {
87- precondition ( self == . sendingResponse, " Invalid state for response complete: \( self ) " )
88- self = . idle
89- }
90- }
91-
9268 private let logger : Logger
9369 private let mode : Mode
9470
9571 private var buffer : ByteBuffer ! = nil
96- private var state : HTTPHandler . State = . idle
9772 private var keepAlive = false
9873
9974 private var requestHead : HTTPRequestHead ?
@@ -125,14 +100,12 @@ private final class HTTPHandler: ChannelInboundHandler {
125100 self . requestHead = request
126101 self . requestBodyBytes = 0
127102 self . keepAlive = request. isKeepAlive
128- self . state. requestReceived ( )
129103 case . body( buffer: var buf) :
130104 logger. trace ( " Received request .body " )
131105 self . requestBodyBytes += buf. readableBytes
132106 self . buffer. writeBuffer ( & buf)
133107 case . end:
134108 logger. trace ( " Received request .end " )
135- self . state. requestComplete ( )
136109
137110 precondition ( requestHead != nil , " Received .end without .head " )
138111 let ( responseStatus, responseHeaders, responseBody) = self . processRequest (
@@ -190,7 +163,6 @@ private final class HTTPHandler: ChannelInboundHandler {
190163 }
191164 let deadline = Int64 ( Date ( timeIntervalSinceNow: 60 ) . timeIntervalSince1970 * 1000 )
192165 responseHeaders = [
193- // ("Connection", "close"),
194166 ( AmazonHeaders . requestID, requestId) ,
195167 ( AmazonHeaders . invokedFunctionARN, " arn:aws:lambda:us-east-1:123456789012:function:custom-runtime " ) ,
196168 ( AmazonHeaders . traceID, " Root=1-5bef4de7-ad49b0e87f6ef6c87fc2e700;Parent=9a9197af755a6419;Sampled=1 " ) ,
@@ -215,8 +187,6 @@ private final class HTTPHandler: ChannelInboundHandler {
215187 trailers: HTTPHeaders ? ,
216188 promise: EventLoopPromise < Void > ?
217189 ) {
218- self . state. responseComplete ( )
219-
220190 let eventLoop = context. eventLoop
221191 let loopBoundContext = NIOLoopBound ( context, eventLoop: eventLoop)
222192
0 commit comments