XRANGE fetches the stream records between two XIDs, inclusive of both the start and end IDs, limited to the count. If you receive the entire count you've asked for, it's reasonable to suppose there might be more items in the given range that were not returned because they would exceed the count – i
(key string, start, stop XID, count int64)
| 536 | // |
| 537 | // Works similar to https://redis.io/commands/xrange |
| 538 | func (c Client) XRANGE(key string, start, stop XID, count int64) (streamItems []StreamItem, err error) { |
| 539 | return c.xRange(key, start, stop, count, true) |
| 540 | } |
| 541 | |
| 542 | func (c Client) xRange(key string, start, stop XID, count int64, forward bool) (streamItems []StreamItem, err error) { |
| 543 | hasMoreResults := true |