compile output

src/apatheia/jobs.nim

@@ -88,3 +88,29 @@ macro submitMacro(tp: untyped, jobs: untyped, exp: untyped): untyped =
 template submit*[T](jobs: JobQueue[T], exp: untyped): Future[T] =
   submitMacro(T, jobs, exp)
 
+when isMainModule:
+  import os
+  import chronos/threadsync
+  import chronos/unittest2/asynctests
+  import std/macros
+
+  proc addNumsRaw(a, b: float): float =
+    os.sleep(50)
+    return a + b
+
+  proc addNums(jobResult: JobResult[float], a, b: float) =
+    let res = addNumsRaw(a, b)
+    discard jobResult.queue.send((jobResult.id, res,))
+
+  suite "async tests":
+
+    var tp = Taskpool.new(num_threads = 2) # Default to the number of hardware threads.
+
+    asyncTest "test":
+      expandMacros:
+        var jobs = newJobQueue[float](taskpool = tp)
+
+        let job = jobs.submit(addNums(1.0, 2.0,))
+        let res = await job
+
+        check res == 3.0