fix: lag can be null (#2448)

holykol · web-flow · commit 3b5361dc1067 · 2023-02-17T21:05:44.000+08:00
see https://github.com/redis/redis/blob/383d902ce68131cf40d6122ce09e305e672e8555/src/t_stream.c#L1456
diff --git a/command.go b/command.go
@@ -2057,7 +2057,7 @@ func (cmd *XInfoGroupsCmd) readReply(rd *proto.Reader) error {
 				}
 			case "lag":
 				group.Lag, err = rd.ReadInt()
-				if err != nil {
+				if err != nil && err != Nil {
 					return err
 				}
 			default:
@@ -2367,7 +2367,7 @@ func readStreamGroups(rd *proto.Reader) ([]XInfoStreamGroup, error) {
 				}
 			case "lag":
 				group.Lag, err = rd.ReadInt()
-				if err != nil {
+				if err != nil && err != Nil {
 					return nil, err
 				}
 			case "pel-count":

Original file line number	Diff line number	Diff line change
`@@ -2057,7 +2057,7 @@ func (cmd XInfoGroupsCmd) readReply(rd proto.Reader) error {`
`2057`	`2057`	`}`
`2058`	`2058`	`case "lag":`
`2059`	`2059`	`group.Lag, err = rd.ReadInt()`
`2060`		`- if err != nil {`
	`2060`	`+ if err != nil && err != Nil {`
`2061`	`2061`	`return err`
`2062`	`2062`	`}`
`2063`	`2063`	`default:`
`@@ -2367,7 +2367,7 @@ func readStreamGroups(rd *proto.Reader) ([]XInfoStreamGroup, error) {`
`2367`	`2367`	`}`
`2368`	`2368`	`case "lag":`
`2369`	`2369`	`group.Lag, err = rd.ReadInt()`
`2370`		`- if err != nil {`
	`2370`	`+ if err != nil && err != Nil {`
`2371`	`2371`	`return nil, err`
`2372`	`2372`	`}`
`2373`	`2373`	`case "pel-count":`