fix(core): update

2023-11-06 20:48:32 +01:00
parent 2c1d9f05ce
commit 62796f7151
2 changed files with 2 additions and 1 deletions
--- a/ts/smartstream.classes.streamintake.ts
+++ b/ts/smartstream.classes.streamintake.ts
@@ -48,5 +48,6 @@ export class StreamIntake<T> extends plugins.stream.Readable {
    this.signalEndBoolean = true;
    this.pushedNextDeferred.resolve();
    this.pushNextObservable.signalComplete();
+    this.push(null);
  }
 }