Struct AgentSender 

pub struct AgentSender { /* private fields */ }

Cloneable command side of a running agent.

Self::send and Self::submit never wait for queue capacity: they return Error::Busy when full and Error::Stopped when disconnected. Successful enqueueing does not mean the operation was accepted; consume the event stream for its correlated outcome.

Dropping all strong senders requests shutdown. Use Agent::into_parts to release the command half while draining AgentEvents until it closes.

Implementations

impl AgentSender

pub fn downgrade(&self) -> WeakAgentSender

Returns a handle that does not keep the agent submission channel open.

pub fn send(&self, submission: Submission) -> Result<()>

Sends a submission with a caller-controlled correlation ID.

pub fn submit(&self, op: Op) -> Result<String>

Submits a command and returns its correlation ID.

Trait Implementations

impl Clone for AgentSender

fn clone(&self) -> AgentSender

Returns a duplicate of the value.

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

Performs copy-assignment from source.