fix: propagate stream errors better

NaturalCycles · Nov 25, 2022 · 65a69f2 · 65a69f2
1 parent 3ac41a1
commit 65a69f2
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/src/mongo.db.ts b/src/mongo.db.ts
@@ -1,4 +1,4 @@
-import { Transform } from 'stream'
+import { Transform } from 'node:stream'
 import {
   BaseCommonDB,
   CommonDB,
@@ -245,6 +245,7 @@ export class MongoDB extends BaseCommonDB implements CommonDB {
           .collection<ROW>(q.table)
           .find(query, options) // eslint-disable-line unicorn/no-array-method-this-argument
           .stream()
+          .on('error', err => transform.emit('error', err))
           .pipe(transform)
       })
       .catch(err => transform.emit('error', err))

diff --git a/src/test/paths.cnst.ts b/src/test/paths.cnst.ts
@@ -1,4 +1,4 @@
-import * as path from 'path'
+import * as path from 'node:path'
 
 export const projectDir = path.join(`${__dirname}/../..`)
 export const tmpDir = `${projectDir}/tmp`