Struct Connection 

pub struct Connection<'b, S, TX, TS, D = NoDelay> { /* private fields */ }

An active Modbus TCP → RTU bridge connection.

Returned by Bridge::accept. Mutably borrows the bridge for its lifetime, preventing a second connection from being accepted until this one is finished.

Drive the connection by calling next in a loop.

Implementations

impl<'b, S, TX, TS, D> Connection<'b, S, TX, TS, D>

pub fn into_stream(self) -> TS

Consumes the connection and returns the underlying TCP stream.

Examples

let socket = conn.into_stream();
socket.close();

impl<S, TX, TS> Connection<'_, S, TX, TS, NoDelay>

where S: Read + Write, TX: OutputPin, TS: Read + Write,

pub async fn next( &mut self, ) -> Result<BridgeEvent, BridgeError<S::Error, TS::Error>>

Drives one complete Modbus request/response cycle asynchronously.

Errors

Returns BridgeError::TcpClosed when the TCP client closes the connection cleanly.

impl<S, TX, TS, D> Connection<'_, S, TX, TS, D>

where S: Read + Write, TX: OutputPin, TS: Read + Write, D: DelayNs,

pub async fn next( &mut self, ) -> Result<BridgeEvent, BridgeError<S::Error, TS::Error>>

Drives one complete Modbus request/response cycle asynchronously, with timeouts.

Applies tcp_timeout_ms around reading the incoming TCP request and rtu_timeout_ms around the RTU send+receive cycle.

Errors

Returns BridgeError::Timeout if a deadline expires.