Fix parallel output using per request standard output.

integration/hurl/tests_ok/stdout.sh

@@ -1,5 +1,5 @@
 #!/bin/bash
 set -Eeuo pipefail
-hurl --verbose tests_ok/stdout.hurl
+hurl --verbose --output - tests_ok/stdout.hurl
 
 

integration/hurl/tests_ok/stdout_parallel.out

@@ -0,0 +1 @@
+HelloHello

integration/hurl/tests_ok/stdout_parallel.ps1

@@ -0,0 +1,4 @@
+Set-StrictMode -Version latest
+$ErrorActionPreference = 'Stop'
+
+hurl --parallel tests_ok/stdout.hurl

integration/hurl/tests_ok/stdout_parallel.sh

@@ -0,0 +1,4 @@
+#!/bin/bash
+set -Eeuo pipefail
+
+hurl --parallel tests_ok/stdout.hurl

packages/hurl/src/parallel/message.rs

@@ -19,7 +19,7 @@ use std::io;
 
 use crate::parallel::job::{Job, JobResult};
 use crate::parallel::worker::WorkerId;
-use crate::util::term::Stderr;
+use crate::util::term::{Stderr, Stdout};
 
 /// Represents a message sent from the worker to the runner (running on the main thread).
 pub enum WorkerMessage {
@@ -110,16 +110,19 @@ pub struct CompletedMsg {
     pub worker_id: WorkerId,
     /// Result execution of the originator job, can successful or failed.
     pub result: JobResult,
+    /// Standard output of the worker for this job.
+    pub stdout: Stdout,
     /// Standard error of the worker for this job.
     pub stderr: Stderr,
 }
 
 impl CompletedMsg {
     /// Creates a new completed message: the job has completed, successfully or not.
-    pub fn new(worker_id: WorkerId, result: JobResult, stderr: Stderr) -> Self {
+    pub fn new(worker_id: WorkerId, result: JobResult, stdout: Stdout, stderr: Stderr) -> Self {
         CompletedMsg {
             worker_id,
             result,
+            stdout,
             stderr,
         }
     }

packages/hurl/src/parallel/runner.rs

@@ -224,6 +224,12 @@ impl ParallelRunner {
                     if !msg.stderr.buffer().is_empty() {
                         stderr.eprint(msg.stderr.buffer());
                     }
+                    if !msg.stdout.buffer().is_empty() {
+                        let ret = stdout.write_all(msg.stdout.buffer());
+                        if ret.is_err() {
+                            return Err(JobError::IO("Issue writing to stdout".to_string()));
+                        }
+                    }
 
                     // Then, we print job output on standard output (the first response truncates
                     // exiting file, subsequent response appends bytes).

packages/hurl/src/parallel/worker.rs

@@ -127,7 +127,7 @@ impl Worker {
                 ));
             }
             let job_result = JobResult::new(job, content, result);
-            let msg = CompletedMsg::new(worker_id, job_result, logger.stderr);
+            let msg = CompletedMsg::new(worker_id, job_result, stdout, logger.stderr);
             _ = tx.send(WorkerMessage::Completed(msg));
         });