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