[rethinkdb] Add missing promise types for cursor.next() (DefinitelyTy…

…ped#45204)
Maxim-Mazurok · Jun 12, 2020 · dd70728 · dd70728
1 parent dcd7613
commit dd70728
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 3 deletions.
diff --git a/types/rethinkdb/index.d.ts b/types/rethinkdb/index.d.ts
@@ -82,6 +82,8 @@ declare module "rethinkdb" {
         each<T>(cb: (err: Error, row: T) => boolean, done?: () => void): void; // returning false stops iteration
         next(cb: (err: Error, row: any) => void): void;
         next<T>(cb: (err: Error, row: T) => void): void;
+        next(): Promise<any>;
+        next<T>(): Promise<T>;
         toArray(cb: (err: Error, rows: any[]) => void): void;
         toArray<T>(cb: (err: Error, rows: T[]) => void): void;
         toArray(): Promise<any[]>;

diff --git a/types/rethinkdb/rethinkdb-tests.ts b/types/rethinkdb/rethinkdb-tests.ts
@@ -98,9 +98,14 @@ r.connect({ host: "localhost", port: 28015 }).then(function(conn: r.Connection)
         .limit(4)
         .run(conn)
         .then((cursor: r.Cursor) => {
-          cursor.toArray().then((rows: any[]) => {
-            console.log(rows);
-          });
+          return cursor.next().then((row) => {
+            console.log('first row', row);
+            return cursor.toArray();
+          }).then((rows) => {
+            console.log('all rows', rows);
+          }).then(() => {
+            return cursor.close();
+          })
         });
     });
 });