From b61416bdf47900fc777b205cafb7b7c8248bb76f Mon Sep 17 00:00:00 2001 From: antirez Date: Wed, 6 Jun 2018 11:40:19 +0200 Subject: [PATCH] Fix streamIteratorRemoveEntry() to update elements count. Close #4989. --- src/t_stream.c | 3 +++ 1 file changed, 3 insertions(+) diff --git a/src/t_stream.c b/src/t_stream.c index fe702110..07af3ff8 100644 --- a/src/t_stream.c +++ b/src/t_stream.c @@ -691,6 +691,9 @@ void streamIteratorRemoveEntry(streamIterator *si, streamID *current) { aux = lpGetInteger(p); lp = lpReplaceInteger(lp,&p,aux+1); + /* Update the number of entries counter. */ + si->stream->length--; + /* Re-seek the iterator to fix the now messed up state. */ streamID start, end; if (si->rev) {