logos-storage/apatheia
1
0
Fork 0
mirror of https://github.com/logos-storage/apatheia.git synced 2026-01-07 15:33:09 +00:00
Code Issues Packages Projects Releases Wiki Activity

queues

Browse Source
This commit is contained in:
Jaremy Creechley 2024-02-09 18:34:56 -07:00
parent e666189efa
commit 0c10e88aa8
No known key found for this signature in database
GPG Key ID: 4E66FB67B21D3300
2 changed files with 12 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/apatheia/queues.nim
View File

@ -1,11 +1,20 @@
import ./types
import chronos import chronos
import results
import chronos/threadsync import chronos/threadsync
export types
type type
AsyncQueue*[T] = object AsyncQueue*[T] = object
signal: ThreadSignalPtr signal: ThreadSignalPtr
item*: T item*: T
proc new*[T](tp: typedesc[AsyncQueue[T]]): AsyncQueue[T] {.raises: [ApatheiaException].} =
let res = ThreadSignalPtr.new()
if res.isErr():
raise newException(ApatheiaException, msg: res.err())

3
src/apatheia/types.nim Normal file
View File

@ -0,0 +1,3 @@
type
ApatheiaException* = ref object of CatchableError