creating queryIterable method

README.md

@@ -345,6 +345,20 @@ main();
 
 ```
 
+######  Query to fetch results (rows) for an async iterable of pages
+
+You can also receive an async iterable that yields all result pages, seamless.
+
+```javascript
+async function main() {
+    const results = athenaExpress.queryIterable("SELECT * from students LIMIT 100", 10);
+	for await (const page of results) {
+    	console.log(page);
+	}
+}
+main();
+
+```
 
 ##### UTILITY queries
 ###### Show Tables (single column result)

index.d.ts

@@ -45,6 +45,7 @@ declare module 'athena-express' {
 
     class AthenaExpress<T> {
         public new: (config: Partial<ConnectionConfigInterface>) => any;
+        public queryIterable(sql: string, pagination?: number): AsyncIterable<QueryResult<T>>;
         public query: QueryFunc<T>;
         constructor(config: Partial<ConnectionConfigInterface>);
     }

lib/athenaExpress.js

@@ -7,6 +7,27 @@ const COST_PER_MB = 0.000004768, //Based on $5/TB
 
 const helpers = require("./helpers.js");
 
+function getNext(query, instance) {
+    let previous;
+    return async () => {
+        if (previous) {
+            if (!previous.NextToken) {
+                return {
+                    done: true
+                };
+            }
+            const { NextToken, QueryExecutionId } = previous;
+            query = { ...query, NextToken, QueryExecutionId };
+        }
+        previous = await instance.query(query);
+
+        return {
+            value: previous,
+            done: !previous.Items || !previous.Items.length,
+        };
+    }
+}
+
 module.exports = class AthenaExpress {
     constructor(init) {
         helpers.validateConstructor(init);
@@ -39,6 +60,25 @@ module.exports = class AthenaExpress {
         };
     }
 
+    queryIterable(sql, pagination = 999) {
+        if (typeof sql !== 'string') {
+            throw new TypeError('sql must be a SQL Statement');
+        }
+        if (typeof pagination !== 'number' || pagination <= 0) {
+            throw new TypeError('pagination must be a positive number');
+        }
+
+        return {
+            [Symbol.asyncIterator]: () => {
+                const query = { sql, pagination };
+
+                return {
+                    next:  getNext(query, this),
+                }
+            }
+        }
+    }
+
     async query(query) {
         const config = this.config;