diff --git a/src/apatheia/queues.nim b/src/apatheia/queues.nim index 9efbcec..84a0157 100644 --- a/src/apatheia/queues.nim +++ b/src/apatheia/queues.nim @@ -26,6 +26,7 @@ proc destroy*[T](val: SignalQueue[T]) = discard val.signal.close() proc newSignalQueue*[T](maxItems: int = 0): SignalQueue[T] {.raises: [ApatheiaSignalErr].} = + ## Create a signal queue compatible with Chronos async let res = ThreadSignalPtr.new() if res.isErr(): raise newException(ApatheiaSignalErr, res.error())