From 33ca4346e4265211924725bc0939a016cca49a3c Mon Sep 17 00:00:00 2001
From: Jaremy Creechley <creechley@gmail.com>
Date: Tue, 26 Sep 2023 14:09:38 -0700
Subject: [PATCH] setup query end

---
 datastore/threads/threadproxyds.nim | 16 ++++++++--------
 1 file changed, 8 insertions(+), 8 deletions(-)

diff --git a/datastore/threads/threadproxyds.nim b/datastore/threads/threadproxyds.nim
index 304c735..8fc0d1e 100644
--- a/datastore/threads/threadproxyds.nim
+++ b/datastore/threads/threadproxyds.nim
@@ -288,14 +288,14 @@ method query*(
     dispatchTask[void](self, signal):
       discard ctx.signal.fireSync()
 
-    # if ctx.res.isErr() and ctx.res.error()[0] == ErrorEnum.QueryEndedErr:
-    #   iter.finished = true
-    #   return
-    # elif ctx.res.isErr():
-    #   return err(ctx.res.error())
-    # else:
-    #   let qres = ctx.res.get()
-    #   return ok(default)
+    if ctx.res.isErr() and ctx.res.error()[0] == ErrorEnum.QueryEndedErr:
+      iter.finished = true
+      return
+    elif ctx.res.isErr():
+      return err(ctx.res.error())
+    else:
+      let qres = ctx.res.get()
+      return ok(default)
 
   iter.next = next
   return success iter