fix(core): update

This commit is contained in:
Philipp Kunz 2023-11-06 21:03:44 +01:00
parent 5e4ec5b837
commit 3e03b81a43
2 changed files with 1 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.8', version: '3.0.9',
description: 'simplifies access to node streams' description: 'simplifies access to node streams'
} }

View File

@ -48,6 +48,5 @@ export class StreamIntake<T> extends plugins.stream.Readable {
this.signalEndBoolean = true; this.signalEndBoolean = true;
this.pushedNextDeferred.resolve(); this.pushedNextDeferred.resolve();
this.pushNextObservable.signalComplete(); this.pushNextObservable.signalComplete();
this.push(null);
} }
} }