diff --git a/src/db.c b/src/db.c index 2219194b..83ffbcc9 100644 --- a/src/db.c +++ b/src/db.c @@ -1422,7 +1422,7 @@ int *xreadGetKeys(struct redisCommand *cmd, robj **argv, int argc, int *numkeys) there are also the IDs, one per key. */ keys = zmalloc(sizeof(int) * num); - for (i = streams_pos+1; i < argc; i++) keys[i-streams_pos-1] = i; + for (i = streams_pos+1; i < argc-num; i++) keys[i-streams_pos-1] = i; *numkeys = num; return keys; }