Skip to content

Commit 6f1a1ac

Browse files
committed
fix: add XInfoConsumers test
Signed-off-by: monkey92t <[email protected]>
1 parent 997ab5e commit 6f1a1ac

File tree

2 files changed

+3
-2
lines changed

2 files changed

+3
-2
lines changed

command.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1906,21 +1906,21 @@ func (cmd *XInfoConsumersCmd) readReply(rd *proto.Reader) error {
19061906
return err
19071907
}
19081908

1909-
var idle int64
19101909
switch key {
19111910
case "name":
19121911
cmd.val[i].Name, err = rd.ReadString()
19131912
case "pending":
19141913
cmd.val[i].Pending, err = rd.ReadInt()
19151914
case "idle":
1915+
var idle int64
19161916
idle, err = rd.ReadInt()
1917+
cmd.val[i].Idle = time.Duration(idle) * time.Millisecond
19171918
default:
19181919
return fmt.Errorf("redis: unexpected content %s in XINFO CONSUMERS reply", key)
19191920
}
19201921
if err != nil {
19211922
return err
19221923
}
1923-
cmd.val[i].Idle = time.Duration(idle) * time.Millisecond
19241924
}
19251925
}
19261926

commands_test.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -5008,6 +5008,7 @@ var _ = Describe("Commands", func() {
50085008
res, err := client.XInfoConsumers(ctx, "stream", "group1").Result()
50095009
Expect(err).NotTo(HaveOccurred())
50105010
for i := range res {
5011+
Expect(res[i].Idle > 0).To(BeTrue())
50115012
res[i].Idle = 0
50125013
}
50135014
Expect(res).To(Equal([]redis.XInfoConsumer{

0 commit comments

Comments
 (0)