Struct OutputReceiver 

pub struct OutputReceiver { /* private fields */ }

Ergonomic wrapper around a broadcast receiver of process output.

Implementations

impl OutputReceiver

pub fn new(rx: Receiver<OutputChunk>) -> Self

pub async fn recv(&mut self) -> Option<OutputChunk>

Receive the next available chunk, skipping lagged messages.

pub fn try_drain(&mut self) -> Vec<OutputChunk>

Drain all immediately available chunks without blocking.

pub fn drain_into(&mut self, buf: &mut HeadTailBuffer)

Drain all immediately available chunks into a buffer, merging streams.

Trait Implementations

impl From<Receiver<OutputChunk>> for OutputReceiver

fn from(rx: Receiver<OutputChunk>) -> Self

Converts to this type from the input type.