Struct MasterSession 

pub struct MasterSession { /* private fields */ }

Owns the “awaiting response” slot(s) for a master. The master calls MasterSession::start when it sends a request, and MasterSession::stop when the response arrives or times out. MasterSession::handle_frame / MasterSession::handle_error are called by the master’s framing / framing_error subscription tasks.

Implementations

impl MasterSession

pub fn new() -> Self

pub fn start( &self, key: WaiterKey, pre_check: Vec<PreCheck>, ) -> Receiver<Result<Framing, ModbusError>>

Arm a waiter under key. Returns a receiver that resolves with either the first matching Framing or a rejection reason.

If key already has a waiter (e.g. TID wrap collision), the previous waiter’s receiver is dropped — equivalent to the caller calling MasterSession::stop first.

pub fn stop(&self, key: WaiterKey)

Drop the waiter under key without notifying it. Used on timeout, where the caller has already given up on the receiver.

pub fn stop_all(&self, err: ModbusError)

Reject every armed waiter with err. Used by handle_error (framing errors lose transaction context) and on master close/destroy.

pub fn has(&self, key: WaiterKey) -> bool

True if a waiter is currently armed under key.

pub fn handle_frame(&self, frame: Framing)

Push a successfully framed PDU at the session. Looks up the waiter keyed by frame.adu.transaction (TCP) or WaiterKey::Fifo (RTU/ASCII). If found, removes it and runs the pre-checks; on the first failing check, rejects with the corresponding error. On all checks passing, resolves with the frame. No-op if no waiter matches.

pub fn handle_error(&self, err: ModbusError)

Push a framing error at the session. Framing errors arrive without transaction context (CRC/LRC failure, bogus MBAP header, etc.), so every in-flight waiter is rejected.

Trait Implementations

impl Default for MasterSession

fn default() -> Self

Returns the “default value” for a type.