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

got together

Browse Source
This commit is contained in:
Jaremy Creechley 2024-02-13 22:52:40 -07:00
parent 3fd3bb2f3d
commit c95fc0875f
No known key found for this signature in database
GPG Key ID: 4E66FB67B21D3300
2 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/apatheia/jobs.nim
View File

@ -63,7 +63,7 @@ macro submitMacro*(tp: untyped, jobs: untyped, exp: untyped): untyped =
let (`jobRes`, `futName`) = createFuture(`jobs`, `nm`) let (`jobRes`, `futName`) = createFuture(`jobs`, `nm`)
`jobs`.taskpool.spawn(`fncall`) `jobs`.taskpool.spawn(`fncall`)
`futName` `futName`
echo "submit: res:\n", result.repr echo "submit: res:\n", result.repr
echo "" echo ""

1
src/apatheia/tasks.nim
View File

@ -53,6 +53,7 @@ macro asyncTask*(p: untyped): untyped =
nnkBracketExpr.newTree(ident"JobResult", retType), nnkBracketExpr.newTree(ident"JobResult", retType),
newEmptyNode() newEmptyNode()
) )
asyncParams[0] = newEmptyNode()
asyncParams.insert(1, jobArg) asyncParams.insert(1, jobArg)
let fn = mkProc(procId, asyncParams, asyncBody) let fn = mkProc(procId, asyncParams, asyncBody)