From 49a050dca1a245634a1c4a643bb577c08118e7e4 Mon Sep 17 00:00:00 2001 From: Jaremy Creechley Date: Fri, 9 Feb 2024 23:05:39 -0700 Subject: [PATCH] setup jobs --- src/apatheia/jobs.nim | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/apatheia/jobs.nim b/src/apatheia/jobs.nim index 06d68a3..e32aa9d 100644 --- a/src/apatheia/jobs.nim +++ b/src/apatheia/jobs.nim @@ -23,11 +23,11 @@ type proc processJobs*(jobs: JobQueue) {.async.} = while jobs.running: echo "jobs running..." - let res = jobs.queue.wait() + let res = await jobs.queue.wait() echo "jobs result: ", res.repr proc newJobQueue*[T](maxItems: int = 0, taskpool: Taskpool = Taskpool.new()): JobQueue[T] {.raises: [ApatheiaSignalErr].} = - result = JobQueue[T](queue: newSignalQueue[(uint, T)](maxItems), taskpool: taskpool) + result = JobQueue[T](queue: newSignalQueue[(uint, T)](maxItems), taskpool: taskpool, running: true) asyncSpawn(processJobs(result)) macro submitMacro*(tp: untyped, jobs: untyped, exp: untyped): untyped =