Struct RtuApplicationLayer 

pub struct RtuApplicationLayer { /* private fields */ }

Implementations

impl RtuApplicationLayer

pub fn new<P: PhysicalLayer + 'static>( physical: Arc<P>, options: RtuApplicationLayerOptions, ) -> Arc<Self>

Build an RTU application layer bound to physical.

Options (all optional; see RtuApplicationLayerOptions for defaults):

• interval_between_frames — overrides the default 3.5T computation.
  • FrameInterval::Bits(n) — n bit-times (default 38.5 = 3.5 char times).
  • FrameInterval::Ms(n) — explicit milliseconds.
  • On serial with None: baud > 19200 → 1.75 ms (spec fix), else ceil((38.5 * 1000) / baud).
• inter_char_timeout — opt-in t1.5. Disabled by default. Same units. On serial: baud > 19200 → 0.75 ms, else ceil((16.5 * 1000) / baud).
• baud_rate — defaults to 9600 for Serial. Ignored on Net.

pub fn add_custom_function_code(&self, cfc: CustomFunctionCode)

Register a custom function code predictor. Required for any non-standard FC; without registration the frame is rejected with a framing error.

pub fn remove_custom_function_code(&self, fc: u8)

Trait Implementations

impl ApplicationLayer for RtuApplicationLayer

fn set_role(&self, role: ApplicationRole) -> Result<(), ModbusError>

Bind the application layer to a master/slave role. Must succeed on the first call and fail (ModbusError::InvalidState) if a different role is then assigned. Re-assigning the same role is a no-op (idempotent).

fn role(&self) -> Option<ApplicationRole>

Current role, or None if not yet assigned.

fn protocol(&self) -> ApplicationProtocol

Wire protocol implemented by this layer. Used by ModbusMaster to validate concurrent configuration at construction time.

fn encode(&self, adu: &ApplicationDataUnit) -> Vec<u8>

Encode an ADU into wire bytes per the protocol’s framing format (MBAP for TCP, CRC for RTU, hex+LRC for ASCII).

fn decode(&self, data: &[u8]) -> Result<FramedDataUnit, ModbusError>

Decode a single complete frame back into an ADU. Returned only for backward compatibility with the previous stateless API; new consumers should subscribe to subscribe_framing instead.

fn flush(&self)

Drop any per-connection state (decoding buffers, timers). Called by Master before each request, by Slave between sessions.

fn subscribe_framing(&self) -> Receiver<Framing>

Subscribe to successfully framed PDUs assembled from the underlying physical layer.

fn subscribe_framing_error(&self) -> Receiver<ModbusError>

Subscribe to framing-level errors (CRC/LRC failure, invalid MBAP header, etc.). One error per offending physical-layer chunk.

fn destroy<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Release task handles and drop physical-layer subscriptions.

fn add_custom_function_code(&self, _cfc: CustomFunctionCode)

Register a custom function code predictor. Default is a no-op; only RtuApplicationLayer overrides this with real behavior.

fn remove_custom_function_code(&self, _fc: u8)

Remove a previously registered custom function code. Default is a no-op.