Skip to content

Commit 86e8536

Browse files
fixed command return type
1 parent 44f9add commit 86e8536

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

stream_commands.go

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -106,12 +106,12 @@ func (c cmdable) XAdd(ctx context.Context, a *XAddArgs) *StringCmd {
106106
return cmd
107107
}
108108

109-
func (c cmdable) XAckDel(ctx context.Context, stream string, group string, mode string, ids ...string) *IntCmd {
109+
func (c cmdable) XAckDel(ctx context.Context, stream string, group string, mode string, ids ...string) *SliceCmd {
110110
args := []interface{}{"xackdel", stream, group, mode, "ids", strconv.Itoa(len(ids))}
111111
for _, id := range ids {
112112
args = append(args, id)
113113
}
114-
cmd := NewIntCmd(ctx, args...)
114+
cmd := NewSliceCmd(ctx, args...)
115115
_ = c(ctx, cmd)
116116
return cmd
117117
}
@@ -126,12 +126,12 @@ func (c cmdable) XDel(ctx context.Context, stream string, ids ...string) *IntCmd
126126
return cmd
127127
}
128128

129-
func (c cmdable) XDelEx(ctx context.Context, stream string, mode string, ids ...string) *IntCmd {
129+
func (c cmdable) XDelEx(ctx context.Context, stream string, mode string, ids ...string) *SliceCmd {
130130
args := []interface{}{"xdelex", stream, mode, "ids", strconv.Itoa(len(ids))}
131131
for _, id := range ids {
132132
args = append(args, id)
133133
}
134-
cmd := NewIntCmd(ctx, args...)
134+
cmd := NewSliceCmd(ctx, args...)
135135
_ = c(ctx, cmd)
136136
return cmd
137137
}

0 commit comments

Comments
 (0)