diff --git a/datastore/datastore.nim b/datastore/datastore.nim
index 98b9520..c0f1f0d 100644
--- a/datastore/datastore.nim
+++ b/datastore/datastore.nim
@@ -34,11 +34,16 @@ method put*(self: Datastore, batch: seq[BatchEntry]): Future[?!void] {.base, loc
 method close*(self: Datastore): Future[?!void] {.base, locks: "unknown", raises: [].} =
   raiseAssert("Not implemented!")
 
-method query*(
-  self: Datastore,
-  query: Query): Future[?!QueryIter] {.base, gcsafe, raises: [].} =
+method query*(self: Datastore,
+              query: Query
+              ): Future[?!QueryIter] {.base, gcsafe, raises: [].} =
 
   raiseAssert("Not implemented!")
 
+method queryIter*(self: Datastore,
+              query: Query
+              ): ?!(iterator(): ?!QueryResponse) {.base, gcsafe, raises: [].} =
+  raiseAssert("Not implemented!")
+
 proc contains*(self: Datastore, key: Key): Future[bool] {.async, raises: [].} =
   return (await self.has(key)) |? false
diff --git a/datastore/sql.nim b/datastore/sql.nim
index d961999..fd22ed6 100644
--- a/datastore/sql.nim
+++ b/datastore/sql.nim
@@ -59,7 +59,7 @@ method put*(self: SQLiteDatastore,
 method close*(self: SQLiteDatastore): Future[?!void] {.async.} =
   self.db.close()
 
-method query*(
+method queryIter*(
   self: SQLiteDatastore,
   query: Query
 ): ?!(iterator(): ?!QueryResponse) =