diff --git a/lib/podlet-stream.js b/lib/podlet-stream.js index 952f5bbc..9d818014 100644 --- a/lib/podlet-stream.js +++ b/lib/podlet-stream.js @@ -47,12 +47,11 @@ export class PodletStream extends EventEmitter { let assets = new Map(); /** @type {Map} */ let contents = new Map(); - /** @type {Map} */ - let done = new Map(); let didEmitBeforeStream = false; /** @type {string[]} */ let queue = []; + let done = 0; for (let podlet of podlets) { podlet @@ -101,12 +100,14 @@ export class PodletStream extends EventEmitter { do { let toEmit = queue.pop(); this.emit('data', toEmit); + done += 1; } while (queue.length !== 0); } this.emit('data', toEmit); + done += 1; - if (done.size === podlets.length) { + if (done === podlets.length) { this.emit('end'); } });