From 3b5361dc1067c36e83ced8fcef5fc785dc09c756 Mon Sep 17 00:00:00 2001 From: Timofey <22733656+holykol@users.noreply.github.com> Date: Fri, 17 Feb 2023 16:05:44 +0300 Subject: [PATCH] fix: lag can be null (#2448) see https://github.com/redis/redis/blob/383d902ce68131cf40d6122ce09e305e672e8555/src/t_stream.c#L1456 --- command.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/command.go b/command.go index d357e922..fa948489 100644 --- 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":