Struct DuplexChannel 

pub struct DuplexChannel { /* private fields */ }

An open duplex session.

send publishes an event to the agent’s input topic and returns its correlation id; recv returns the next output event the agent produced. Ack / pong / connected frames are consumed transparently by recv.

Implementations

impl DuplexChannel

pub async fn send( &mut self, payload: &Value, correlation_id: Option<&str>, ) -> Result<String, PulseError>

Publish payload to the agent’s input topic.

Returns the correlation id (generated when correlation_id is None) that the matching output will carry.

pub async fn recv(&mut self) -> Result<DuplexOutput, PulseError>

Return the next agent output event.

Skips ack / pong / connected frames transparently. An error frame surfaces as PulseError::Validation.

pub async fn close(self) -> Result<(), PulseError>

Close the channel cleanly.

Trait Implementations

impl Debug for DuplexChannel

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

Formats the value using the given formatter.