@@ -48,7 +48,7 @@ describe("XDELEX", () => {
48
48
testUtils . testAll (
49
49
`XDELEX non-existing key - without policy` ,
50
50
async ( client ) => {
51
- const reply = await client . xDelex ( "{tag}stream-key" , "0-0" ) ;
51
+ const reply = await client . xDelEx ( "{tag}stream-key" , "0-0" ) ;
52
52
assert . deepEqual ( reply , [ STREAM_DELETION_REPLY_CODES . NOT_FOUND ] ) ;
53
53
} ,
54
54
{
@@ -65,10 +65,9 @@ describe("XDELEX", () => {
65
65
field : "value" ,
66
66
} ) ;
67
67
68
- const reply = await client . xDelex (
68
+ const reply = await client . xDelEx (
69
69
streamKey ,
70
70
messageId ,
71
- STREAM_DELETION_POLICY . KEEPREF
72
71
) ;
73
72
assert . deepEqual ( reply , [ STREAM_DELETION_REPLY_CODES . DELETED ] ) ;
74
73
} ,
@@ -86,7 +85,7 @@ describe("XDELEX", () => {
86
85
field : "value" ,
87
86
} ) ;
88
87
89
- const reply = await client . xDelex (
88
+ const reply = await client . xDelEx (
90
89
streamKey ,
91
90
messageId ,
92
91
STREAM_DELETION_POLICY . DELREF
@@ -112,7 +111,7 @@ describe("XDELEX", () => {
112
111
// Create consumer group
113
112
await client . xGroupCreate ( streamKey , "testgroup" , "0" ) ;
114
113
115
- const reply = await client . xDelex (
114
+ const reply = await client . xDelEx (
116
115
streamKey ,
117
116
messageId ,
118
117
STREAM_DELETION_POLICY . ACKED
@@ -138,7 +137,7 @@ describe("XDELEX", () => {
138
137
} ) ,
139
138
] ) ;
140
139
141
- const reply = await client . xDelex (
140
+ const reply = await client . xDelEx (
142
141
streamKey ,
143
142
[ ...messageIds , "0-0" ] ,
144
143
STREAM_DELETION_POLICY . DELREF
0 commit comments