Commit 5f8c57f2 authored by antirez's avatar antirez
Browse files

CG: test XACK ability to remove items from the PELs.

parent f5799e72
...@@ -58,4 +58,17 @@ start_server { ...@@ -58,4 +58,17 @@ start_server {
set pending [r XPENDING mystream mygroup - + 10 client-1] set pending [r XPENDING mystream mygroup - + 10 client-1]
assert {[llength $pending] == 2} assert {[llength $pending] == 2}
} }
test {XACK is able to remove items from the client/group PEL} {
set pending [r XPENDING mystream mygroup - + 10 client-1]
set id1 [lindex $pending 0 0]
set id2 [lindex $pending 1 0]
assert {[r XACK mystream mygroup $id1] eq 1}
set pending [r XPENDING mystream mygroup - + 10 client-1]
assert {[llength $pending] == 1}
set id [lindex $pending 0 0]
assert {$id eq $id2}
set global_pel [r XPENDING mystream mygroup - + 10]
assert {[llength $global_pel] == 3}
}
} }
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment