Public declaration syntax from forge-rs/crates/forge-agent/src/messaging.rs
Original source SHA-256: 626d88e8fbf1c56d30fc05a883e4e1887b61ce3eb9f9624f263173e6f654e4ad
Function bodies and constant values are omitted. This is not the complete implementation.

Source line 71
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct AgentMessage {

}

Source line 107
pub fn text(
        sender: impl Into<String>,
        recipient: impl Into<String>,
        payload: impl Into<String>,
    ) -> Self;

Source line 140
pub fn result(
        sender: impl Into<String>,
        recipient: impl Into<String>,
        payload: impl Into<String>,
    ) -> Self;

Source line 173
pub fn error(
        sender: impl Into<String>,
        recipient: impl Into<String>,
        payload: impl Into<String>,
    ) -> Self;

Source line 207
pub fn control(
        sender: impl Into<String>,
        recipient: impl Into<String>,
        payload: impl Into<String>,
    ) -> Self;

Source line 221
pub fn sender(&self) -> &str;

Source line 226
pub fn recipient(&self) -> &str;

Source line 231
pub fn payload(&self) -> &str;

Source line 236
pub fn kind(&self) -> &str;

Source line 264
#[derive(Debug, Clone)]
pub struct AgentChannelSender {

}

Source line 298
pub async fn send(&self, message: AgentMessage) -> ForgeAgentResult<()>;

Source line 333
pub fn try_send(&self, message: AgentMessage) -> ForgeAgentResult<()>;

Source line 361
#[derive(Debug)]
pub struct AgentChannelReceiver {

}

Source line 388
pub async fn recv(&mut self) -> Option<AgentMessage>;

Source line 411
pub fn try_recv(&mut self) -> Option<AgentMessage>;

Source line 448
pub struct AgentChannel;

Source line 472
#[allow(clippy::new_ret_no_self)]
pub fn new(capacity: usize) -> (AgentChannelSender, AgentChannelReceiver);