From aec0459ec38aca58b8acee8f0e85d75f29e5b294 Mon Sep 17 00:00:00 2001 From: Jaremy Creechley Date: Tue, 29 Aug 2023 20:37:10 -0700 Subject: [PATCH] query iterator using items is breaks when the DS isn't blocking --- datastore/query.nim | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/datastore/query.nim b/datastore/query.nim index 1d98e3b..aa26bdf 100644 --- a/datastore/query.nim +++ b/datastore/query.nim @@ -32,8 +32,10 @@ type proc waitForAllQueryResults*(qi: Future[?!QueryIter]): Future[?!seq[QueryResponse]] {.async.} = ## for large blocks this would be *expensive* var res: seq[QueryResponse] - without iter =? (await qi), err: - return failure err + let iterRes = await qi + if iterRes.isErr(): + return failure iterRes.error() + let iter = iterRes.get() while not iter.finished: let val = await iter.next()