Struct EmbeddedLeg 

pub struct EmbeddedLeg<R, W, const N: usize> { /* private fields */ }

Available on crate feature embedded only.

Length-prefix transport over embedded-io-async byte streams.

See the module docs for the SessionTransport hook-up story.

Implementations

impl<R, W, const N: usize> EmbeddedLeg<R, W, N>

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

Wrap a pre-split (reader, writer) pair. Most embassy UART/USB HALs offer a .split() that produces compatible halves; a non-splittable shared bus needs a caller-side wrapper.

pub fn into_inner(self) -> (R, W)

Recover the inner (reader, writer); consumes the leg.

impl<R, W, const N: usize> EmbeddedLeg<R, W, N>

where R: Read, W: Write,

pub async fn send_frame(&self, data: &[u8]) -> Result<(), CoreError>

Send one framed message: 4-byte big-endian length prefix + payload. Errors if data.len() exceeds the leg’s buffer N or u32::MAX, or on any transport error from W.

pub async fn recv_frame(&self) -> Result<Bytes, CoreError>

Receive one framed message. Returns the payload as a fresh Bytes. Returns CoreError::ConnectionClosed on EOF; CoreError::NetworkError on framing errors or transport errors.