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) {