@@ -65,35 +65,10 @@ private final class HTTPHandler: ChannelInboundHandler {
65
65
public typealias InboundIn = HTTPServerRequestPart
66
66
public typealias OutboundOut = HTTPServerResponsePart
67
67
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
-
92
68
private let logger : Logger
93
69
private let mode : Mode
94
70
95
71
private var buffer : ByteBuffer ! = nil
96
- private var state : HTTPHandler . State = . idle
97
72
private var keepAlive = false
98
73
99
74
private var requestHead : HTTPRequestHead ?
@@ -125,14 +100,12 @@ private final class HTTPHandler: ChannelInboundHandler {
125
100
self . requestHead = request
126
101
self . requestBodyBytes = 0
127
102
self . keepAlive = request. isKeepAlive
128
- self . state. requestReceived ( )
129
103
case . body( buffer: var buf) :
130
104
logger. trace ( " Received request .body " )
131
105
self . requestBodyBytes += buf. readableBytes
132
106
self . buffer. writeBuffer ( & buf)
133
107
case . end:
134
108
logger. trace ( " Received request .end " )
135
- self . state. requestComplete ( )
136
109
137
110
precondition ( requestHead != nil , " Received .end without .head " )
138
111
let ( responseStatus, responseHeaders, responseBody) = self . processRequest (
@@ -190,7 +163,6 @@ private final class HTTPHandler: ChannelInboundHandler {
190
163
}
191
164
let deadline = Int64 ( Date ( timeIntervalSinceNow: 60 ) . timeIntervalSince1970 * 1000 )
192
165
responseHeaders = [
193
- // ("Connection", "close"),
194
166
( AmazonHeaders . requestID, requestId) ,
195
167
( AmazonHeaders . invokedFunctionARN, " arn:aws:lambda:us-east-1:123456789012:function:custom-runtime " ) ,
196
168
( AmazonHeaders . traceID, " Root=1-5bef4de7-ad49b0e87f6ef6c87fc2e700;Parent=9a9197af755a6419;Sampled=1 " ) ,
@@ -215,8 +187,6 @@ private final class HTTPHandler: ChannelInboundHandler {
215
187
trailers: HTTPHeaders ? ,
216
188
promise: EventLoopPromise < Void > ?
217
189
) {
218
- self . state. responseComplete ( )
219
-
220
190
let eventLoop = context. eventLoop
221
191
let loopBoundContext = NIOLoopBound ( context, eventLoop: eventLoop)
222
192
0 commit comments