Struct JobStreams 

pub struct JobStreams {
    pub stdout: Arc<BoundedStream>,
    pub stderr: Arc<BoundedStream>,
}

One job’s live output streams.

Handed out by JobManager::streams so a producer (the drain task behind an external command) can write into a job that outlives the command, and so an embedder can tail a running job with BoundedStream::changed_since instead of a poll loop.

Fields

stdout: Arc<BoundedStream>

The job’s stdout, written as the bytes arrive.

Fed two ways, and never both for the same bytes:

• Live, per 8 KiB chunk, by the drain task behind an external command running for this job — but only from the stage whose stdout is the job’s stdout (Only or Last in the pipeline), so a | b streams b and not a’s bytes on their way into b.
• At completion, from the job’s captured ExecResult, and only when nothing was streamed live. That covers a builtin-only job (echo hi &): a builtin returns its output as a value when it finishes, so there is no byte stream to tee.

Whichever fed it, the stream is closed once the job’s result is in (JobManager::finalize_streams), so a reader can tell “no more coming” from “nothing yet”.

stderr: Arc<BoundedStream>

The job’s stderr. Same two feeds as Self::stdout, except the live one takes every stage’s stderr, not just the last — stderr is not piped between stages. The consequence, stated rather than papered over: in a job mixing builtins and externals, once any external has written stderr the completion write is skipped, so a builtin stage’s stderr stays in the job’s ExecResult and does not reach this stream.

Trait Implementations

impl Clone for JobStreams

fn clone(&self) -> JobStreams

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.