netxserver 2.2.0

netx server assembly.
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

use crate::async_token::NetxToken;
use crate::result::RetResult;
use anyhow::Result;
use data_rw::DataOwnedReader;
use std::sync::Arc;

/// Trait representing a controller that can handle calls.
pub trait IController: Send + Sync {
    /// Handles a call with the given parameters.
    ///
    /// # Parameters
    /// - `tt`: A `u8` representing the type.
    /// - `cmd_tag`: An `i32` representing the command tag.
    /// - `dr`: A `DataOwnedReader` instance.
    ///
    /// # Returns
    /// A future that resolves to a `Result` containing a `RetResult`.
    fn call(
        &self,
        tt: u8,
        cmd_tag: i32,
        dr: DataOwnedReader,
    ) -> impl std::future::Future<Output = Result<RetResult>> + Send;
}

/// Trait for creating controllers.
pub trait ICreateController {
    type Controller: IController;

    /// Creates a new controller.
    ///
    /// # Parameters
    /// - `token`: A `NetxToken` for the controller.
    ///
    /// # Returns
    /// A `Result` containing an `Arc` to the created controller.
    fn create_controller(
        &self,
        token: NetxToken<Self::Controller>,
    ) -> Result<Arc<Self::Controller>>;
}