Struct TcpConnection 

pub struct TcpConnection { /* private fields */ }

A persistent TCP connection with length-prefixed framing.

Implementations

impl TcpConnection

pub fn from_stream(stream: TcpStream) -> Self

Wrap an already-connected TcpStream into a TcpConnection.

Trait Implementations

impl Connection for TcpConnection

fn send(&mut self, payload: &[u8]) -> Result<(), TransportError>

Send a framed payload over the connection.

fn recv(&mut self, timeout: Option<Duration>) -> Result<Vec<u8>, TransportError>

Receive a framed payload. If timeout is None, blocks indefinitely.

fn close(&mut self) -> Result<(), TransportError>

Close the connection gracefully.

fn supports_sidecars(&self) -> bool

Whether this connection supports out-of-band sidecar delivery.

fn send_sidecar(&mut self, payload: &[u8]) -> Result<(), TransportError>

Send a sidecar payload. Default: falls back to send().

fn recv_any( &mut self, timeout: Option<Duration>, ) -> Result<Vec<u8>, TransportError>

Receive any incoming message (regular or sidecar). Default: falls back to recv().