test query

This commit is contained in:
Jaremy Creechley 2023-09-26 18:14:30 -07:00
parent 4e63ca48f0
commit d411b56175
No known key found for this signature in database
GPG Key ID: 4E66FB67B21D3300

View File

@ -276,16 +276,15 @@ proc queryTask[DB](
echo "\tqueryTask:query:iter:wait! "
discard nextSignal.waitSync().get()
echo "\tqueryTask:query:iter:wait:done "
if ctx[].cancelled:
echo "\tqueryTask:query:iter:cancelled"
# cancel iter, then run next cycle so it'll finish and close
handle.cancel = true
continue
else:
echo "\tqueryTask:query:iter:result:"
ctx[].res = item.mapErr() do(exc: ref CatchableError) -> ThreadResErr:
exc
echo "\tqueryTask:query:iter:result: ", ctx[].res
echo "\tqueryTask:query:iter:fireSync "
discard ctx[].signal.fireSync()