From 6c95c29267045b48a9aef286dc0ede8fe7da8420 Mon Sep 17 00:00:00 2001 From: Jaremy Creechley Date: Tue, 26 Sep 2023 18:11:06 -0700 Subject: [PATCH] test query --- datastore/threads/threadproxyds.nim | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/datastore/threads/threadproxyds.nim b/datastore/threads/threadproxyds.nim index c79a181..c986108 100644 --- a/datastore/threads/threadproxyds.nim +++ b/datastore/threads/threadproxyds.nim @@ -274,7 +274,7 @@ proc queryTask[DB]( for item in handle.iter(): # wait for next request from async thread echo "\tqueryTask:query:iter:wait! " - discard ctx[].signal.waitSync().get() + discard nextSignal.waitSync().get() echo "\tqueryTask:query:iter:wait:done " if ctx[].cancelled: @@ -344,7 +344,7 @@ method query*( echo "query:next:iter:dispatch" await ctx[].signal.fire() echo "query:next:iter:dispatch:wait" - await wait(ctx[].signal) + await wait(nextSignal) echo "query:next:iter:res: ", ctx[].res