diff --git a/contrib/codecs/rdwr/codec.go b/contrib/codecs/rdwr/codec.go
index b7774d8e5127af77ae210c02f6cbdcfc3e5b924b..c741f0bac3ef33b0057b38e7e2bd88ac58072ccf 100644
--- a/contrib/codecs/rdwr/codec.go
+++ b/contrib/codecs/rdwr/codec.go
@@ -91,7 +91,10 @@ func (c *Codec) Flush() (err error) {
 	c.wrLock.Lock()
 	defer c.wrLock.Unlock()
 	if c.wr.Buffered() > 0 {
-		c.wr.WriteByte('\n')
+		err = c.wr.WriteByte('\n')
+		if err != nil {
+			return err
+		}
 		err = c.wr.Flush()
 		if err != nil {
 			return err