test changes in SpawnAsync.run

Author: aspeddro

tests/docstrings_examples/DocTest.res

@@ -40,6 +40,8 @@ module Node = {
     @send
     external once: (spawnReturns, string, (Js.Null.t<float>, Js.Null.t<string>) => unit) => unit =
       "once"
+    @send
+    external onceError: (spawnReturns, string, Js.Exn.t => unit) => unit = "once"
   }
 
   module OS = {
@@ -92,17 +94,20 @@ module SpawnAsync = {
     code: Null.t<float>,
   }
   let run = async (~command, ~args, ~options=?) => {
-    await Promise.make((resolve, _reject) => {
-      let spawn = ChildProcess.spawn(command, args, ~options?)
-      let stdout = []
-      let stderr = []
-      spawn.stdout->ChildProcess.on("data", data => {
-        Array.push(stdout, data)
-      })
-      spawn.stderr->ChildProcess.on("data", data => {
-        Array.push(stderr, data)
+    let spawn = ChildProcess.spawn(command, args, ~options?)
+    let stdout = []
+    let stderr = []
+    spawn.stdout->ChildProcess.on("data", data => {
+      Array.push(stdout, data)
+    })
+    spawn.stderr->ChildProcess.on("data", data => {
+      Array.push(stderr, data)
+    })
+    await Promise.make((resolve, reject) => {
+      spawn->ChildProcess.once("error", (_, _) => {
+        reject({stdout, stderr, code: Null.make(1.0)})
       })
-      spawn->ChildProcess.onFromSpawn("close", code => {
+      spawn->ChildProcess.once("close", (code, _signal) => {
         resolve({stdout, stderr, code})
       })
     })
@@ -374,8 +379,6 @@ let main = async () => {
       // Await the next iterator value
       let {value, done} = await asyncIterator->AsyncIterator.next
 
-      Console.log2(value, Array.length(chuncks))
-
       // Exit the while loop if the iterator says it's done
       break := done
 
@@ -402,6 +405,8 @@ let main = async () => {
 
   let () = await processMyAsyncIterator()
 
+  Console.log("Compiation tests finished")
+
   let compilationResults = result->Array.flat
 
   // let compilationResults =

tests/docstrings_examples/DocTest.res.mjs

@@ -62,17 +62,22 @@ let v = values["ignore-runtime-tests"];
 let ignoreRuntimeTests = v !== undefined ? v.split(",").map(s => s.trim()) : [];
 
 async function run(command, args, options) {
-  return await new Promise((resolve, _reject) => {
-    let spawn = Child_process.spawn(command, args, options !== undefined ? Primitive_option.valFromOption(options) : undefined);
-    let stdout = [];
-    let stderr = [];
-    spawn.stdout.on("data", data => {
-      stdout.push(data);
-    });
-    spawn.stderr.on("data", data => {
-      stderr.push(data);
-    });
-    spawn.on("close", code => resolve({
+  let spawn = Child_process.spawn(command, args, options !== undefined ? Primitive_option.valFromOption(options) : undefined);
+  let stdout = [];
+  let stderr = [];
+  spawn.stdout.on("data", data => {
+    stdout.push(data);
+  });
+  spawn.stderr.on("data", data => {
+    stderr.push(data);
+  });
+  return await new Promise((resolve, reject) => {
+    spawn.once("error", (param, param$1) => reject({
+      stdout: stdout,
+      stderr: stderr,
+      code: 1.0
+    }));
+    spawn.once("close", (code, _signal) => resolve({
       stdout: stdout,
       stderr: stderr,
       code: code
@@ -183,7 +188,7 @@ function extractDocFromFile(file) {
       RE_EXN_ID: "Assert_failure",
       _1: [
         "DocTest.res",
-        199,
+        204,
         9
       ],
       Error: new Error()
@@ -381,7 +386,6 @@ async function main() {
     while (!$$break) {
       let match = await asyncIterator.next();
       let value = match.value;
-      console.log(value, chuncks.length);
       $$break = match.done;
       if (value !== undefined) {
         let c = chuncks[value];
@@ -403,6 +407,7 @@ async function main() {
     };
   };
   await processMyAsyncIterator();
+  console.log("Compiation tests finished");
   let compilationResults = result.flat();
   let match = $$Array.reduce(compilationResults, [
     [],