()
| 291 | |
| 292 | // Read stdout in parallel |
| 293 | const readStdout = async () => { |
| 294 | try { |
| 295 | while (true) { |
| 296 | const { done, value } = await stdoutReader.read(); |
| 297 | if (done) break; |
| 298 | loggers.stdout.append(decoder.decode(value, { stream: true })); |
| 299 | } |
| 300 | loggers.stdout.flush(); |
| 301 | } finally { |
| 302 | stdoutReader.releaseLock(); |
| 303 | } |
| 304 | }; |
| 305 | |
| 306 | // Read stderr in parallel |
| 307 | const readStderr = async () => { |
no test coverage detected