We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 1d38146 commit 62b4ddcCopy full SHA for 62b4ddc
1 file changed
reader.go
@@ -44,9 +44,13 @@ func (c *RespReader) readReply() error {
44
return nil
45
case '$':
46
n, err := parseLen(line[1:])
47
- if n < 0 || err != nil {
+ if err != nil {
48
return err
49
}
50
+ if n < 0 {
51
+ c.bw.WriteString("$-1\r\n")
52
+ return nil
53
+ }
54
p := make([]byte, n+2)
55
_, err = io.ReadFull(c.br, p)
56
if err != nil {
@@ -60,9 +64,13 @@ func (c *RespReader) readReply() error {
60
64
61
65
case '*':
62
66
63
67
68
69
70
71
+ c.bw.WriteString("*-1\r\n")
72
73
74
c.bw.Write(line)
75
for range n {
76
err = c.readReply()
0 commit comments