diff --git a/command.go b/command.go index 6681ff5..0c30bcb 100644 --- a/command.go +++ b/command.go @@ -165,13 +165,7 @@ func (cmd *Cmd) readReply(cn *pool.Conn) error { cmd.err = err return cmd.err } - if v, ok := val.([]byte); ok { - // Convert to string to preserve old behaviour. - // TODO: remove in v4 - cmd.val = string(v) - } else { - cmd.val = val - } + cmd.val = val return nil } diff --git a/redis_test.go b/redis_test.go index fc0d702..9d4a360 100644 --- a/redis_test.go +++ b/redis_test.go @@ -132,7 +132,7 @@ var _ = Describe("Client", func() { cmd := redis.NewCmd("PING") client.Process(cmd) Expect(cmd.Err()).NotTo(HaveOccurred()) - Expect(cmd.Val()).To(Equal("PONG")) + Expect(cmd.Val()).To(Equal([]byte("PONG"))) }) It("should retry command on network error", func() {