use plimit

Author: larshp

packages/cli/src/file_operations.ts

@@ -71,10 +71,14 @@ export class FileOperations {
     return files;
   }
 
-  public static writeFiles(files: {path: string, contents: string}[]) {
-    for (const file of files) {
-      fs.writeFileSync(file.path, file.contents);
-    }
+  public static async writeFiles(files: {path: string, contents: string}[]) {
+    const limit = this.setupPLimit();
+    const promises = files.map((file) => {
+      return limit(async () => {
+        await fsPromises.writeFile(file.path, file.contents);
+      });
+    });
+    await Promise.all(promises);
   }
 
 }

packages/cli/src/index.ts

@@ -70,7 +70,9 @@ async function loadLib(config: ITranspilerConfig): Promise<Transpiler.IFile[]> {
   return files;
 }
 
-function writeObjects(outputFiles: Transpiler.IOutputFile[], config: ITranspilerConfig, outputFolder: string, files: Transpiler.IFile[]) {
+async function writeObjects(outputFiles: Transpiler.IOutputFile[],
+  config: ITranspilerConfig, outputFolder: string, files: Transpiler.IFile[]) {
+
   const writeSourceMaps = config.write_source_map || false;
   const filesToWrite: {path: string, contents: string}[] = [];
 
@@ -104,7 +106,7 @@ function writeObjects(outputFiles: Transpiler.IOutputFile[], config: ITranspiler
     filesToWrite.push({path: outputFolder + path.sep + output.filename, contents});
   }
 
-  FileOperations.writeFiles(filesToWrite);
+  await FileOperations.writeFiles(filesToWrite);
 }
 
 async function build(config: ITranspilerConfig, files: Transpiler.IFile[]) {
@@ -139,7 +141,7 @@ async function run() {
     fs.mkdirSync(outputFolder);
   }
 
-  writeObjects(output.objects, config, outputFolder, files);
+  await writeObjects(output.objects, config, outputFolder, files);
   console.log(output.objects.length + " objects written to disk");
 
   if (config.write_unit_tests === true) {