Struct ChioTransport 

pub struct ChioTransport<R: Read, W: Write> { /* private fields */ }

Length-prefixed canonical JSON transport.

Reads AgentMessage frames from the reader and writes KernelMessage frames to the writer. Each frame is a 4-byte big-endian length prefix followed by that many bytes of canonical JSON.

Implementations

impl<R: Read, W: Write> ChioTransport<R, W>

pub fn new(reader: R, writer: W) -> Self

pub fn recv(&mut self) -> Result<AgentMessage, TransportError>

Read one AgentMessage from the transport.

Blocks until a complete frame is available. Returns TransportError::ConnectionClosed if the reader reaches EOF before a complete frame is read.

pub fn send(&mut self, msg: &KernelMessage) -> Result<(), TransportError>

Send one KernelMessage over the transport.

The message is serialized to canonical JSON (RFC 8785) and written as a length-prefixed frame. The writer is flushed after each send.