Loading src/render_worker.ts +9 −1 Original line number Diff line number Diff line Loading @@ -68,9 +68,11 @@ parentPort?.on("message", (msg: Message) => { let index = msg.frameStart; let needsInit = true; let nextTime = msg.start; let nextPixels = getPixelsAsLog(nextTime, nextTime + msg.step); for (let time = msg.start; time < msg.end; time += msg.step) { const pixels = await getPixelsAsLog(time, time + msg.step); const pixels = await nextPixels; log("generating frame " + index); Loading Loading @@ -132,6 +134,12 @@ parentPort?.on("message", (msg: Message) => { ); } // run db query in paralell nextTime = time + msg.step; if (nextTime < msg.end) { nextPixels = getPixelsAsLog(nextTime, nextTime + msg.step); } // Encode current canvas state to PNG and write const data = await canvas.encode("png"); await fs.promises.writeFile( Loading Loading
src/render_worker.ts +9 −1 Original line number Diff line number Diff line Loading @@ -68,9 +68,11 @@ parentPort?.on("message", (msg: Message) => { let index = msg.frameStart; let needsInit = true; let nextTime = msg.start; let nextPixels = getPixelsAsLog(nextTime, nextTime + msg.step); for (let time = msg.start; time < msg.end; time += msg.step) { const pixels = await getPixelsAsLog(time, time + msg.step); const pixels = await nextPixels; log("generating frame " + index); Loading Loading @@ -132,6 +134,12 @@ parentPort?.on("message", (msg: Message) => { ); } // run db query in paralell nextTime = time + msg.step; if (nextTime < msg.end) { nextPixels = getPixelsAsLog(nextTime, nextTime + msg.step); } // Encode current canvas state to PNG and write const data = await canvas.encode("png"); await fs.promises.writeFile( Loading