add tests for new ds'es

This commit is contained in:
Jaremy Creechley 2023-08-30 18:46:30 -07:00 committed by Dmitriy Ryajov
parent 619d3e9d56
commit 24ce85e49b
No known key found for this signature in database
GPG Key ID: DA8C680CE7C657A4
2 changed files with 6 additions and 3 deletions

View File

@ -51,7 +51,7 @@ proc waitForAllQueryResults*(qi: ?!QueryIter): Future[?!seq[QueryResponse]] {.as
proc waitForAllQueryResults*(iter: Future[?!QueryIter]): Future[?!seq[QueryResponse]] {.async.} =
let res = await iter
await waitForAllQueryResults(res)
return await waitForAllQueryResults(res)
proc defaultDispose(): Future[?!void] {.upraises: [], gcsafe, async.} =
return success()

View File

@ -25,6 +25,9 @@ suite "Datastore (base)":
test "query":
expect Defect:
let iter = tryGet(await waitForAllQueryResults ds.query(Query.init(key)))
for n in iter:
let
q = Query.init(key)
all = waitForAllQueryResults(await ds.query(q))
res = tryGet(await all)
for n in res:
discard