mirror of
https://github.com/fluencelabs/redis
synced 2025-04-25 18:42:13 +00:00
Streams: add some initial test for XREVRANGE.
This commit is contained in:
parent
115d076d65
commit
45fe1f5e00
@ -121,6 +121,10 @@ start_server {
|
|||||||
assert {[llength [r xrange mystream - + COUNT 10]] == 10}
|
assert {[llength [r xrange mystream - + COUNT 10]] == 10}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
test {XREVRANGE COUNT works as expected} {
|
||||||
|
assert {[llength [r xrevrange mystream + - COUNT 10]] == 10}
|
||||||
|
}
|
||||||
|
|
||||||
test {XRANGE can be used to iterate the whole stream} {
|
test {XRANGE can be used to iterate the whole stream} {
|
||||||
set last_id "-"
|
set last_id "-"
|
||||||
set j 0
|
set j 0
|
||||||
@ -136,6 +140,10 @@ start_server {
|
|||||||
assert {$j == 10000}
|
assert {$j == 10000}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
test {XREVRANGE returns the reverse of XRANGE} {
|
||||||
|
assert {[r xrange mystream - +] == [lreverse [r xrevrange mystream + -]]}
|
||||||
|
}
|
||||||
|
|
||||||
test {XREAD with non empty stream} {
|
test {XREAD with non empty stream} {
|
||||||
set res [r XREAD COUNT 1 STREAMS mystream 0.0]
|
set res [r XREAD COUNT 1 STREAMS mystream 0.0]
|
||||||
assert {[lrange [lindex $res 0 1 0 1] 0 1] eq {item 0}}
|
assert {[lrange [lindex $res 0 1 0 1] 0 1] eq {item 0}}
|
||||||
|
Loading…
x
Reference in New Issue
Block a user