Fix RedisCommandHandler never reaching error state

Mordil · Mordil · commit 6fe37cb7e466 · 2020-09-08T10:56:44.000-07:00
diff --git a/Sources/RediStack/ChannelHandlers/RedisCommandHandler.swift b/Sources/RediStack/ChannelHandlers/RedisCommandHandler.swift
@@ -83,6 +83,7 @@ extension RedisCommandHandler: ChannelInboundHandler {
     }
     
     private func _failCommandQueue(because error: Error) {
+        self.state = .error(error)
         let queue = self.commandResponseQueue
         self.commandResponseQueue.removeAll()
         queue.forEach { $0.fail(error) }

Original file line number	Diff line number	Diff line change
`@@ -83,6 +83,7 @@ extension RedisCommandHandler: ChannelInboundHandler {`
`83`	`83`	`}`
`84`	`84`
`85`	`85`	`private func _failCommandQueue(because error: Error) {`
	`86`	`+ self.state = .error(error)`
`86`	`87`	`let queue = self.commandResponseQueue`
`87`	`88`	`self.commandResponseQueue.removeAll()`
`88`	`89`	`queue.forEach { $0.fail(error) }`