8
8
9
9
type StreamCmdable interface {
10
10
XAdd (ctx context.Context , a * XAddArgs ) * StringCmd
11
- XAckDel (ctx context.Context , stream string , group string , mode string , ids ... string ) * IntCmd
11
+ XAckDel (ctx context.Context , stream string , group string , mode string , ids ... string ) * SliceCmd
12
12
XDel (ctx context.Context , stream string , ids ... string ) * IntCmd
13
- XDelEx (ctx context.Context , stream string , mode string , ids ... string ) * IntCmd
13
+ XDelEx (ctx context.Context , stream string , mode string , ids ... string ) * SliceCmd
14
14
XLen (ctx context.Context , stream string ) * IntCmd
15
15
XRange (ctx context.Context , stream , start , stop string ) * XMessageSliceCmd
16
16
XRangeN (ctx context.Context , stream , start , stop string , count int64 ) * XMessageSliceCmd
@@ -106,12 +106,12 @@ func (c cmdable) XAdd(ctx context.Context, a *XAddArgs) *StringCmd {
106
106
return cmd
107
107
}
108
108
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 {
110
110
args := []interface {}{"xackdel" , stream , group , mode , "ids" , strconv .Itoa (len (ids ))}
111
111
for _ , id := range ids {
112
112
args = append (args , id )
113
113
}
114
- cmd := NewIntCmd (ctx , args ... )
114
+ cmd := NewSliceCmd (ctx , args ... )
115
115
_ = c (ctx , cmd )
116
116
return cmd
117
117
}
@@ -126,12 +126,12 @@ func (c cmdable) XDel(ctx context.Context, stream string, ids ...string) *IntCmd
126
126
return cmd
127
127
}
128
128
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 {
130
130
args := []interface {}{"xdelex" , stream , mode , "ids" , strconv .Itoa (len (ids ))}
131
131
for _ , id := range ids {
132
132
args = append (args , id )
133
133
}
134
- cmd := NewIntCmd (ctx , args ... )
134
+ cmd := NewSliceCmd (ctx , args ... )
135
135
_ = c (ctx , cmd )
136
136
return cmd
137
137
}
0 commit comments