fix return -1

distributedio · Jan 21, 2019 · 995df90 · 995df90
1 parent 367a45f
commit 995df90
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/encoding/resp/resp.go b/encoding/resp/resp.go
@@ -226,6 +226,11 @@ func (r *Decoder) BulkString() (string, error) {
 		return "", ErrInvalidProtocol
 	}
 
+	if hdr[0] == '-' && len(hdr) == 2 && hdr[1] == '1' {
+		// handle $-1 and $-1 null replies.
+		return "", nil
+	}
+
 	remain, err := strconv.Atoi(string(hdr[1 : l-2]))
 	if err != nil || remain < 0 {
 		return "", ErrInvalidProtocol