From be9b236c06c5755f08471c7a106084548c363a08 Mon Sep 17 00:00:00 2001 From: Jaremy Creechley Date: Fri, 9 Feb 2024 21:59:35 -0700 Subject: [PATCH] rename queue --- src/apatheia/queues.nim | 4 ++++ tests/config.nims | 1 + 2 files changed, 5 insertions(+) diff --git a/src/apatheia/queues.nim b/src/apatheia/queues.nim index b4e483d..27f005e 100644 --- a/src/apatheia/queues.nim +++ b/src/apatheia/queues.nim @@ -22,6 +22,10 @@ type signal: ThreadSignalPtr chan*: ChanPtr[T] +proc destroy*[T](val: SignalQueue[T]) = + deallocShared(val.chan) + discard val.signal.close() + proc newSignalQueue*[T](maxItems: int = 0): SignalQueue[T] {.raises: [ApatheiaSignalErr].} = let res = ThreadSignalPtr.new() if res.isErr(): diff --git a/tests/config.nims b/tests/config.nims index a418ce0..8b57598 100644 --- a/tests/config.nims +++ b/tests/config.nims @@ -1,3 +1,4 @@ switch("path", "$projectDir/../src") --threads:on +--mm:refc