mbus-async 0.14.0

Native async Modbus client and server stack for Tokio-based applications
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51

//! Async Modbus server — zero-boilerplate and explicit-loop APIs.
//!
//! # Quick start
//!
//! ```rust,ignore
//! use mbus_async::server::{AsyncTcpServer, ModbusRequest, ModbusResponse, AsyncAppHandler};
//! use mbus_core::transport::UnitIdOrSlaveAddr;
//!
//! struct MyApp;
//!
//! impl AsyncAppHandler for MyApp {
//!     async fn handle(&mut self, req: ModbusRequest) -> ModbusResponse {
//!         ModbusResponse::NoResponse
//!     }
//! }
//!
//! #[tokio::main]
//! async fn main() {
//!     let unit = UnitIdOrSlaveAddr::try_from(1u8).unwrap();
//!     AsyncTcpServer::serve("0.0.0.0:502", MyApp, unit).await.unwrap();
//! }
//! ```

pub mod app_handler;
pub mod session;
#[cfg(feature = "diagnostics-stats")]
pub mod statistics;

#[cfg(feature = "server-tcp")]
pub mod tcp_server;

#[cfg(feature = "server-serial")]
pub mod serial_server;

// Flat re-exports for ergonomic use.
pub use app_handler::{
    AsyncAppHandler, AsyncAppRequirements, AsyncServerError, ModbusRequest, ModbusResponse,
};
#[cfg(feature = "traffic")]
pub use app_handler::{AsyncServerTrafficNotifier, AsyncTrafficDirection};
pub use session::AsyncServerSession;
#[cfg(feature = "diagnostics-stats")]
pub use statistics::AsyncServerStatistics;

#[cfg(feature = "server-tcp")]
pub use tcp_server::AsyncTcpServer;

#[cfg(feature = "server-serial")]
pub use serial_server::{AsyncAsciiServer, AsyncRtuServer, AsyncSerialServer};

pub use mbus_macros::async_modbus_app;