fix bug

radkesvat · Apr 24, 2024 · 37d7bb4 · 37d7bb4
1 parent c31f34d
commit 37d7bb4
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/ww/buffer_stream.c b/ww/buffer_stream.c
@@ -13,11 +13,12 @@ buffer_stream_t *newBufferStream(struct buffer_pool_s *pool)
 void empytBufferStream(buffer_stream_t *self)
 {
     c_foreach(i, queue, self->q) { reuseBuffer(self->pool, *i.ref); }
+    queue_clear(&self->q);
 }
 
 void destroyBufferStream(buffer_stream_t *self)
 {
-    empytBufferStream(self);
+    c_foreach(i, queue, self->q) { reuseBuffer(self->pool, *i.ref); }
     queue_drop(&self->q);
     free(self);
 }