Struct StreamingSession 

pub struct StreamingSession { /* private fields */ }

A live streaming session connected to an agent subprocess.

stdin is piped for sending NDJSON messages, stdout is piped for reading NDJSON events. The session owns the child process.

Implementations

impl StreamingSession

pub async fn send(&mut self, message: &str) -> Result<()>

Send a raw NDJSON line to the agent’s stdin.

The message should be a single JSON object (no trailing newline needed).

pub async fn send_user_message(&mut self, content: &str) -> Result<()>

Send a user message to the agent.

Formats the content as a {"type":"user_message","content":"..."} NDJSON line.

pub async fn next_event(&mut self) -> Result<Option<Event>>

Read the next event from the agent’s stdout.

Returns None when stdout is closed (agent exited). Skips lines that fail to parse as JSON events.

pub fn close_input(&mut self)

Close the stdin pipe, signaling no more input to the agent.

pub async fn wait(self) -> Result<()>

Wait for the agent process to exit.

Consumes the session. Returns an error if the process exits with a non-zero status.