From 0fedfcfc002bcb16bdd9c0189a258d2300b97ba2 Mon Sep 17 00:00:00 2001 From: Jaremy Creechley Date: Tue, 26 Sep 2023 18:40:04 -0700 Subject: [PATCH] test query - it runs! --- datastore/query.nim | 2 +- datastore/threads/threadproxyds.nim | 3 +++ 2 files changed, 4 insertions(+), 1 deletion(-) diff --git a/datastore/query.nim b/datastore/query.nim index 477d04d..256ad97 100644 --- a/datastore/query.nim +++ b/datastore/query.nim @@ -37,7 +37,7 @@ proc new*(T: type QueryIter, dispose = defaultDispose): T = proc init*(T: type Query, key: Key, - value = false, + value = true, sort = SortOrder.Ascending, offset = 0, limit = -1): Query = diff --git a/datastore/threads/threadproxyds.nim b/datastore/threads/threadproxyds.nim index ffba89f..a704d40 100644 --- a/datastore/threads/threadproxyds.nim +++ b/datastore/threads/threadproxyds.nim @@ -276,9 +276,12 @@ proc queryTask[DB]( handle.cancel = true continue else: + if item.isOk: + echo "\tqueryTask:query:iter:result:data: ", $item.get().data 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()