Fix queues destruction in io context

1 files changed, 4 insertions, 2 deletions

diff --git a/io_context.c b/io_context.c
index 38a7d13..8b9aa7c 100644
--- a/io_context.c
+++ b/io_context.c
@@ -295,9 +295,11 @@ void IoContextDestroy(struct IoContext* io_context) {
   assert(thrd_join(io_context->thread, NULL) == thrd_success);
   cnd_destroy(&io_context->cond);
   mtx_destroy(&io_context->mutex);
-  for (void* item; QueuePop(&io_context->prio, &item); free(item));
+  for (void* item; QueuePop(&io_context->prio, &item);)
+    ((struct Proto*)item)->Destroy(item);
   QueueDestroy(&io_context->prio);
-  for (void* item; QueuePop(&io_context->queue, &item); free(item));
+  for (void* item; QueuePop(&io_context->queue, &item);)
+    ((struct Proto*)item)->Destroy(item);
   QueueDestroy(&io_context->queue);
   assert(!close(io_context->fd));
   free(io_context);