Struct Channel 

pub struct Channel { /* private fields */ }

Blocking, length-prefixed JSON channel over a Unix stream socket.

Uses 4-byte big-endian length + JSON payload for robustness.

Implementations

impl Channel

pub fn new(stream: UnixStream) -> Self

pub fn send<T: Serialize>(&mut self, msg: &T) -> Result<()>

Send a serializable message.

pub fn recv<T: for<'de> Deserialize<'de>>(&mut self) -> Result<Option<T>>

Receive a deserializable message. Blocks until a message arrives. Returns Ok(None) on clean EOF (peer closed).

pub fn set_read_timeout(&mut self, timeout: Option<Duration>) -> Result<()>

Set a read timeout on the underlying socket. After this, recv() will return an error if no data arrives within the given duration (instead of blocking forever).

pub fn try_clone(&self) -> Result<Self>

Clone the underlying fd for use in a second thread.