Struct StdioChannel 

pub(super) struct StdioChannel {
    rx: Option<Receiver<Message>>,
    pub(super) tx: Option<StdioSender>,
}

A stdio channel of a pipe, see StdioSender.

Fields

rx: Option<Receiver<Message>>

Until the channel got closed, consumers read clones of it.

tx: Option<StdioSender>

Until the read loop of the pipe took it, once the process got connected.

Implementations

impl StdioChannel

pub(super) fn new(capacity: usize, consumed: &Arc<AtomicBool>) -> Self

fn close(&mut self)

Close the channel and drop what it buffers right away, a quiet container would keep the buffered chunks otherwise. The read loop drops its sender once it notices, which frees the channel.

Trait Implementations

impl Debug for StdioChannel

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.