fix(core): update

This commit is contained in:
Philipp Kunz 2023-11-04 00:17:03 +01:00
parent 1b6e38c040
commit 34cbf28972
2 changed files with 4 additions and 2 deletions

View File

@ -3,6 +3,6 @@
*/ */
export const commitinfo = { export const commitinfo = {
name: '@push.rocks/smartstream', name: '@push.rocks/smartstream',
version: '3.0.6', version: '3.0.7',
description: 'simplifies access to node streams' description: 'simplifies access to node streams'
} }

View File

@ -13,7 +13,9 @@ export class PassThrough extends plugins.stream.Duplex {
if (this.push(chunk, encoding)) { if (this.push(chunk, encoding)) {
callback(); callback();
} else { } else {
this.once('drain', callback); this.once('drain', () => {
callback();
});
} }
} }
} }