Struct GuardedStream 

pub struct GuardedStream { /* private fields */ }

Guards a child process for the lifetime of a streaming response.

When the stream is dropped (after natural completion or early cancellation), the child process is killed and the stderr drain task is aborted. This prevents zombie processes and resource leaks.

All fields are Unpin, so GuardedStream is Unpin and the Stream impl can safely access inner fields through Pin<&mut Self>.

Implementations

impl GuardedStream

pub fn new( inner: impl Stream<Item = Result<StreamChunk, RunnerError>> + Send + 'static, child: Child, stderr_task: JoinHandle<Vec<u8>>, ) -> Self

Create a guarded stream wrapping a child process.

The stderr_task drains the child’s stderr in the background to prevent buffer-full deadlocks where the child blocks on write to a full stderr pipe.

Trait Implementations

impl Drop for GuardedStream

fn drop(&mut self)

Executes the destructor for this type.

impl Stream for GuardedStream

type Item = Result<StreamChunk, RunnerError>

Values yielded by the stream.

fn poll_next( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Option<Self::Item>>

Attempt to pull out the next value of this stream, registering the current task for wakeup if the value is not yet available, and returning None if the stream is exhausted.

fn size_hint(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the stream.