From 8a36e252fa9c637c8c6b4f85517a17adb238f020 Mon Sep 17 00:00:00 2001 From: Jaremy Creechley Date: Fri, 9 Feb 2024 22:29:02 -0700 Subject: [PATCH] setup jobs --- src/apatheia/jobs.nim | 2 +- tests/tjobs.nim | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/src/apatheia/jobs.nim b/src/apatheia/jobs.nim index 3d2f4a6..a3bc3e0 100644 --- a/src/apatheia/jobs.nim +++ b/src/apatheia/jobs.nim @@ -17,6 +17,6 @@ type proc newJobQueue*[T](maxItems: int = 0, taskpool: Taskpool = Taskpool.new()): JobQueue[T] {.raises: [ApatheiaSignalErr].} = JobQueue[T](queue: newSignalQueue[T](maxItems), taskpool: taskpool) -template awaitJob*[T](jobs: JobQueue[T], exp: typed): auto = +template submit*[T](jobs: JobQueue[T], exp: typed): Future[T] = jobs.taskpool.spawn(exp) await wait(jobs.queue) diff --git a/tests/tjobs.nim b/tests/tjobs.nim index a5e4029..6bcab8a 100644 --- a/tests/tjobs.nim +++ b/tests/tjobs.nim @@ -29,7 +29,7 @@ suite "async tests": asyncTest "test": echo "\nstart" - let res = jobs.awaitJob(addNums(jobs.queue, 1.0, 2.0)).get() + let res = await jobs.submit(addNums(jobs.queue, 1.0, 2.0)) # await sleepAsync(100.milliseconds) echo "result: ", res.repr