Struct StdioSender 

pub(crate) struct StdioSender {
    pub(super) tx: Sender<Message>,
    consumed: Arc<AtomicBool>,
}

The sending half of a stdio channel, which a read loop forwards the output of its pipe to.

Until a consumer attached, see ContainerIO::consume_stdio, the channel keeps the latest chunks only and drops the oldest one when it is full. The output of a container must never wait for a consumer which may not exist, only the stderr of a failed runtime is of interest. Once one attached, a full channel makes the read loop wait, so that a slow consumer gets all output and the process waits for it instead. An exec gets its consumer before its runtime starts, see ContainerIO::collect_stdio. The consumer closes the channel when it is done, the read loop drops the sender then and keeps reading the pipe.

Fields

tx: Sender<Message>

consumed: Arc<AtomicBool>

Implementations

impl StdioSender

pub(crate) fn new(tx: Sender<Message>, consumed: &Arc<AtomicBool>) -> Self

A sender on tx, whose consumer sets consumed once it attached.

pub(super) fn consumed(&self) -> bool

Whether a consumer reads the channel, see ContainerIO::consume_stdio.

pub(super) async fn send(&self, message: Message) -> bool

Send a message, false if the channel got closed or all receivers are gone.

Trait Implementations

impl Debug for StdioSender

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

Formats the value using the given formatter.