From be70ddb25099d085430661fb098c9101269b96db Mon Sep 17 00:00:00 2001 From: Jaremy Creechley Date: Tue, 26 Sep 2023 18:20:05 -0700 Subject: [PATCH] test query --- datastore/threads/threadproxyds.nim | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/datastore/threads/threadproxyds.nim b/datastore/threads/threadproxyds.nim index d2af41e..fd6f09f 100644 --- a/datastore/threads/threadproxyds.nim +++ b/datastore/threads/threadproxyds.nim @@ -345,17 +345,15 @@ method query*( echo "query:next:iter:dispatch:wait" await wait(ctx[].signal) - echo "query:next:iter:res: ", ctx[].res + echo "query:next:iter:res: ", ctx[].res, "\n" if not ctx[].running: echo "query:next:iter:finished " iter.finished = true if ctx[].res.isErr(): - echo "query:next:iter:res:err " return err(ctx[].res.error()) else: - echo "query:next:iter:res:ok " let qres = ctx[].res.get() let key = qres.key.map(proc (k: KeyId): Key = k.toKey()) let data = qres.data.toSeq()