From 57530229490db203c07b2a477aa9f46cc39bb7e6 Mon Sep 17 00:00:00 2001 From: Timofey Date: Fri, 17 Feb 2023 11:21:22 +0000 Subject: [PATCH] fix: lag can be null 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 d357e922d..fa948489e 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":