From 42a81541426a7a392e0a77076d29274be99f6c62 Mon Sep 17 00:00:00 2001 From: Jean-Louis Huynen Date: Mon, 25 May 2020 16:48:18 +0200 Subject: [PATCH] chg: [inputreader] adds \n on each line --- inputreader/redisreader.go | 1 + 1 file changed, 1 insertion(+) diff --git a/inputreader/redisreader.go b/inputreader/redisreader.go index f0345c2..7574a95 100644 --- a/inputreader/redisreader.go +++ b/inputreader/redisreader.go @@ -54,6 +54,7 @@ func (rl *RedisLPOPReader) Read(p []byte) (n int, err error) { } else if err != nil { return 0, err } + buf = append(buf, "\n"...) rreader := bytes.NewReader(buf) n, err = rreader.Read(p) return n, err