Skip to content

Commit ad4d0a5

Browse files
authored
fix #1766
1 parent 37f5a2b commit ad4d0a5

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

commands.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1773,7 +1773,7 @@ func (c cmdable) XReadGroup(ctx context.Context, a *XReadGroupArgs) *XStreamSlic
17731773
args := make([]interface{}, 0, 8+len(a.Streams))
17741774
args = append(args, "xreadgroup", "group", a.Group, a.Consumer)
17751775

1776-
keyPos := int8(1)
1776+
keyPos := int8(4)
17771777
if a.Count > 0 {
17781778
args = append(args, "count", a.Count)
17791779
keyPos += 2

0 commit comments

Comments
 (0)