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