logos-storage/apatheia
1
0
Fork 0
mirror of https://github.com/logos-storage/apatheia.git synced 2026-01-05 22:43:10 +00:00
Code Issues Packages Projects Releases Wiki Activity

rename queue

Browse Source
This commit is contained in:
Jaremy Creechley 2024-02-09 21:52:37 -07:00
parent e4242132f7
commit 8732cc13fb
No known key found for this signature in database
GPG Key ID: 4E66FB67B21D3300
2 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/apatheia/queues.nim
View File

@ -59,5 +59,6 @@ proc tryRecv*[T](c: SignalQueue[T]): Option[T] =
if res.dataAvailable: if res.dataAvailable:
some res.msg some res.msg
proc wait*[T](c: SignalQueue[T]) {.async.} = proc wait*[T](c: SignalQueue[T]): Future[Result[T, string]] {.async.} =
await wait(c.signal) await wait(c.signal)
return c.recv()

4
tests/tasyncsEx2.nim
View File

@ -27,8 +27,8 @@ suite "async tests":
# await sleepAsync(100.milliseconds) # await sleepAsync(100.milliseconds)
echo "waiting on queue" echo "waiting on queue"
await wait(queue).wait(1500.milliseconds) let res = await wait(queue).wait(1500.milliseconds)
echo "result: ", queue.recv() echo "result: ", res
# echo "\nRES: ", args.value # echo "\nRES: ", args.value