propagate error in mongo stream

This commit is contained in:
SPRINX0\prochazka
2025-03-03 16:05:12 +01:00
parent 8067cff9bd
commit 3f3160406f

View File

@@ -266,6 +266,11 @@ const driver = {
pass.write(transformMongoData(row));
});
// propagate error
cursorStream.on('error', (err) => {
pass.emit('error', err);
});
// Called once the cursor is fully read
cursorStream.on('end', () => {
pass.emit('end');