Struct StreamReceiver 

pub struct StreamReceiver(/* private fields */);

A receiver for observing the message stream.

This allows you to receive copies of all messages flowing through the connection, useful for debugging, logging, or building development tools.

Example

use agent_client_protocol::{StreamReceiver, StreamMessageDirection};

async fn monitor_messages(mut receiver: StreamReceiver) {
    while let Ok(message) = receiver.recv().await {
        match message.direction {
            StreamMessageDirection::Incoming => println!("← Received: {:?}", message.message),
            StreamMessageDirection::Outgoing => println!("→ Sent: {:?}", message.message),
        }
    }
}

Implementations

impl StreamReceiver

pub async fn recv(&mut self) -> Result<StreamMessage>

Receives the next message from the stream.

This method will wait until a message is available or the sender is dropped.

Returns

• Ok(StreamMessage) when a message is received
• Err when the sender is dropped or the receiver is lagged