From 24748cd769c5ae20c3f9fd19962c6f0e546afb8b Mon Sep 17 00:00:00 2001
From: Jaremy Creechley <creechley@gmail.com>
Date: Tue, 26 Sep 2023 18:18:05 -0700
Subject: [PATCH] test query

---
 datastore/threads/threadproxyds.nim | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/datastore/threads/threadproxyds.nim b/datastore/threads/threadproxyds.nim
index 369481c..d2af41e 100644
--- a/datastore/threads/threadproxyds.nim
+++ b/datastore/threads/threadproxyds.nim
@@ -274,7 +274,6 @@ proc queryTask[DB](
       for item in handle.iter():
         # wait for next request from async thread
         echo "\tqueryTask:query:iter:wait! "
-        discard nextSignal.waitSync().get()
 
         if ctx[].cancelled:
           echo "\tqueryTask:query:iter:cancelled"
@@ -287,6 +286,7 @@ proc queryTask[DB](
           echo "\tqueryTask:query:iter:result: ", ctx[].res
           echo "\tqueryTask:query:iter:fireSync "
           discard ctx[].signal.fireSync()
+          discard nextSignal.waitSync().get()
 
       # set final result
       echo "\tqueryTask:query:iter:done "