watch: Making writeOutput calls synchronous (#19)

* Making writeOutput calls synchronous. * fixup
apexlang · Jan 20, 2023 · a313aba · a313aba
1 parent 1951674
commit a313aba
Showing 1 changed file with 15 additions and 16 deletions.
diff --git a/src/commands/watch.ts b/src/commands/watch.ts
@@ -50,28 +50,14 @@ async function watch(configurations: string[]) {
 
           let confs = specMap[p];
           if (confs) {
-            for (const conf of confs) {
-              try {
-                const outputs = await processConfiguration(conf);
-                outputs.forEach((output) => writeOutput(output));
-              } catch (e) {
-                log.error(e);
-              }
-            }
+            await processAndWrite(confs);
           }
 
           confs = configMap[p];
           if (confs) {
             watcher.close();
             await reloadConfigurations();
-            for (const conf of confs) {
-              try {
-                const outputs = await processConfiguration(conf);
-                outputs.forEach((output) => writeOutput(output));
-              } catch (e) {
-                log.error(e);
-              }
-            }
+            await processAndWrite(confs);
             return;
           }
         }
@@ -138,3 +124,16 @@ async function watch(configurations: string[]) {
     });
   });
 }
+
+async function processAndWrite(confs: Configuration[]) {
+  for (const conf of confs) {
+    try {
+      const outputs = await processConfiguration(conf);
+      for (const output of outputs) {
+        await writeOutput(output);
+      }
+    } catch (e) {
+      log.error(e);
+    }
+  }
+}