fix: DatastoreStreamReadable to catch theoretical runNextQuery errors

NaturalCycles · Jul 30, 2024 · 3c48823 · 3c48823
1 parent 980114e
commit 3c48823
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/src/DatastoreStreamReadable.ts b/src/DatastoreStreamReadable.ts
@@ -192,7 +192,10 @@ export class DatastoreStreamReadable<T = any> extends Readable implements Readab
     }
 
     if (!this.running) {
-      void this.runNextQuery()
+      void this.runNextQuery().catch(err => {
+        console.log('error in runNextQuery', err)
+        this.emit('error', err)
+      })
     } else {
       this.logger.log(`_read ${this.count}, wasRunning: true`)
     }