logos-storage/apatheia
1
0
Fork 0
mirror of https://github.com/logos-storage/apatheia.git synced 2026-01-02 13:03:11 +00:00
Code Issues Packages Projects Releases Wiki Activity

docs

Browse Source
This commit is contained in:
Jaremy Creechley 2024-02-14 22:07:57 -07:00
parent dbaebc26fe
commit ede73f9463
1 changed files with 1 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
src/apatheia/queues.nim
View File

@ -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())