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

cleanup

Browse Source
This commit is contained in:
Jaremy Creechley 2024-02-14 22:02:17 -07:00
parent 16b2c10bbf
commit f1b953db81
2 changed files with 3 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
tests/tjobs.nim
View File

@ -15,8 +15,7 @@ import apatheia/jobs
import std/macros import std/macros
proc addNumsRaw(a, b: float): float = proc addNumsRaw(a, b: float): float =
os.sleep(500) os.sleep(50)
echo "adding: ", a, " + ", b
return a + b return a + b
proc addNums(jobResult: JobResult[float], a, b: float) = proc addNums(jobResult: JobResult[float], a, b: float) =
@ -33,13 +32,7 @@ suite "async tests":
asyncTest "test": asyncTest "test":
var jobs = newJobQueue[float](taskpool = tp) var jobs = newJobQueue[float](taskpool = tp)
echo "\nstart"
let res = await jobs.submit(addNums(1.0, 2.0,)) let res = await jobs.submit(addNums(1.0, 2.0,))
# await sleepAsync(100.milliseconds) check res == 3.0
echo "result: ", res.repr
# echo "\nRES: ", args.value
check true

2
tests/ttasks.nim
View File

@ -12,7 +12,7 @@ import apatheia/tasks
## ##
proc addNums(a, b: float): float {.asyncTask.} = proc addNums(a, b: float): float {.asyncTask.} =
os.sleep(100) os.sleep(50)
return a + b return a + b
proc addNumValues(vals: openArray[float]): float {.asyncTask.} = proc addNumValues(vals: openArray[float]): float {.asyncTask.} =