File tree Expand file tree Collapse file tree 1 file changed +0
-3
lines changed
Sources/RediStack/ChannelHandlers Expand file tree Collapse file tree 1 file changed +0
-3
lines changed Original file line number Diff line number Diff line change @@ -76,8 +76,6 @@ extension RedisCommandHandler: ChannelInboundHandler {
7676 public func errorCaught( context: ChannelHandlerContext , error: Error ) {
7777 let queue = self . commandResponseQueue
7878
79- assert ( queue. count > 0 , " Received unexpected error while idle: \( error. localizedDescription) " )
80-
8179 self . commandResponseQueue. removeAll ( )
8280 queue. forEach { $0. fail ( error) }
8381
@@ -95,7 +93,6 @@ extension RedisCommandHandler: ChannelInboundHandler {
9593 let value = self . unwrapInboundIn ( data)
9694
9795 guard let leadPromise = self . commandResponseQueue. popFirst ( ) else {
98- assertionFailure ( " Read triggered with an empty promise queue! Ignoring: \( value) " )
9996 self . logger. critical ( " Read triggered with no promise waiting in the queue! " )
10097 return
10198 }
You can’t perform that action at this time.
0 commit comments