Struct SharedWriter 

pub(crate) struct SharedWriter {
    writer_tx: UnboundedSender<WriterCmd>,
    bound: Duration,
}

Cloneable writer half of Subprocess - pushes onto the writer task’s mpsc. Multiple clones can write concurrently; the writer task serialises onto the child’s stdin in arrival order.

Returned by Subprocess::clone_writer. Used by detached control_request dispatch.

Fields

writer_tx: UnboundedSender<WriterCmd>

bound: Duration

The writer task’s own bound, so this side can derive the wait that outlasts it (see SharedWriter::ack_wait).

Implementations

impl SharedWriter

fn ack_wait(&self) -> Duration

How long a caller waits for a write’s ack: twice the writer’s own bound, so the task’s verdict lands first for a line it dequeued and no line is written after its caller was told it failed.

impl SharedWriter

pub(crate) async fn write_line(&self, line: &str) -> Result<(), Error>

Write one line of stream-json to the transport. Caller supplies the trailing \n.

Errors

Error::Io on write failure or after the transport has closed its write half.

pub(crate) async fn end_input(&self) -> Result<(), Error>

Close the write half so the remote sees EOF on stdin. Idempotent.

Errors

Error::Io on flush failure.

Trait Implementations

impl Clone for SharedWriter

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SharedWriter

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

Formats the value using the given formatter.