Make sure the channel is flushed

helje5 · helje5 · commit 7d74e47d65f3 · 2024-01-29T23:59:25.000+01:00
Errors didn't get properly flushed (i.e. written).
diff --git a/Sources/NIORedis/RESPChannelHandler.swift b/Sources/NIORedis/RESPChannelHandler.swift
@@ -56,6 +56,7 @@ open class RESPChannelHandler : ChannelDuplexHandler {
       try parser.feed(buffer) { respValue in
         self.channelRead(context: context, value: respValue)
       }
+      context.flush()
     }
     catch {
       context.fireErrorCaught(error)

Original file line number	Diff line number	Diff line change
`@@ -56,6 +56,7 @@ open class RESPChannelHandler : ChannelDuplexHandler {`
`56`	`56`	`try parser.feed(buffer) { respValue in`
`57`	`57`	`self.channelRead(context: context, value: respValue)`
`58`	`58`	`}`
	`59`	`+ context.flush()`
`59`	`60`	`}`
`60`	`61`	`catch {`
`61`	`62`	`context.fireErrorCaught(error)`