diff --git a/src/t_stream.c b/src/t_stream.c index 7b1076b1..5a526332 100644 --- a/src/t_stream.c +++ b/src/t_stream.c @@ -757,6 +757,7 @@ int streamDeleteItem(stream *s, streamID *id) { streamIteratorRemoveEntry(&si,&myid); deleted = 1; } + streamIteratorStop(&si); return deleted; }