Enum Handle 

pub enum Handle {
    Stdout,
    Stdin(Arc<Mutex<ChildStdin>>),
    Collect(Arc<Mutex<Vec<Output<Value>>>>),
    Stream(UnboundedSender<Output<Value>>),
}

Destination for super::Output::emit.

Arc<tokio::sync::Mutex<_>> on the non-unit variants lets the handle be cloned cheaply across the command tree’s call chain and guarantees concurrent emits serialize correctly. tokio::sync::Mutex (not std::sync::Mutex) because we hold the guard across .await boundaries during async writes, which would deadlock with std’s.

Variants

Stdout

Write each line to this process’s stdout; mirror fatal Output::Error lines to stderr.

Stdin(Arc<Mutex<ChildStdin>>)

Write each line to a child process’s stdin.

Collect(Arc<Mutex<Vec<Output<Value>>>>)

Push each emitted Output<T> (reserialized as Output<Value> for a uniform storage type) into a shared vector.

Stream(UnboundedSender<Output<Value>>)

Forward each emitted Output<T> through an mpsc channel (reserialized as Output<Value> to match Collect’s storage type). The receiver loops on rx.recv() until the cli’s run() completes and the Handle is dropped — at which point the sender side closes and the receiver’s loop exits.

Implementations

impl Handle

pub async fn emit<T: Serialize>(&self, output: &Output<T>)

Emit output to this destination. Panics on write failure to match println! semantics.

Trait Implementations

impl Clone for Handle

fn clone(&self) -> Handle

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for Handle

fn default() -> Self

Returns the “default value” for a type.