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()