@@ -342,15 +342,14 @@ internal final class HTTPBin<RequestHandler: ChannelInboundHandler> where
342342 socketAddress = try ! SocketAddress ( unixDomainSocketPath: path)
343343}
344344
345- let activeConnCounterHandler = CountActiveConnectionsHandler ( )
346- self . activeConnCounterHandler = activeConnCounterHandler
345+ self . activeConnCounterHandler = CountActiveConnectionsHandler ( )
347346
348347let connectionIDAtomic = NIOAtomic< Int> . makeAtomic( value: 0 )
349348
350349self . serverChannel = try ! ServerBootstrap ( group: self . group)
351350. serverChannelOption ( ChannelOptions . socket ( SocketOptionLevel ( SOL_SOCKET) , SO_REUSEADDR) , value: 1 )
352351. serverChannelInitializer { channel in
353- channel. pipeline. addHandler ( activeConnCounterHandler)
352+ channel. pipeline. addHandler ( self . activeConnCounterHandler)
354353} . childChannelInitializer { channel in
355354do {
356355let connectionID = connectionIDAtomic. add ( 1 )
@@ -364,7 +363,7 @@ internal final class HTTPBin<RequestHandler: ChannelInboundHandler> where
364363try self . syncAddHTTPProxyHandlers (
365364 to: channel,
366365 connectionID: connectionID,
367- expectedAuthroization : expectedAuthorization
366+ expectedAuthorization : expectedAuthorization
368367)
369368return channel. eventLoop. makeSucceededVoidFuture ( )
370369}
@@ -392,14 +391,14 @@ internal final class HTTPBin<RequestHandler: ChannelInboundHandler> where
392391private func syncAddHTTPProxyHandlers(
393392 to channel: Channel ,
394393 connectionID: Int ,
395- expectedAuthroization : String ?
394+ expectedAuthorization : String ?
396395) throws {
397396let sync = channel. pipeline. syncOperations
398397let promise = channel. eventLoop. makePromise ( of: Void . self)
399398
400399let responseEncoder = HTTPResponseEncoder ( )
401400let requestDecoder = ByteToMessageHandler ( HTTPRequestDecoder ( leftOverBytesStrategy: . forwardBytes) )
402- let proxySimulator = HTTPProxySimulator ( promise: promise, expectedAuhorization: expectedAuthroization )
401+ let proxySimulator = HTTPProxySimulator ( promise: promise, expectedAuhorization: expectedAuthorization )
403402
404403try sync. addHandler ( responseEncoder)
405404try sync. addHandler ( requestDecoder)
0 commit comments