Struct Actor

pub struct Actor<I> { /* private fields */ }

Actor Model Ensure Thread safety and high performance writing

Implementations

impl<I> Actor<I>

where I: 'static,

pub fn new(x: I) -> Actor<I>

pub async fn inner_call<T, R>( &self, call: impl FnOnce(Arc<InnerStore<I>>) -> T, ) -> R

where T: Future<Output = R>,

Behavior through queues,thread safe call async fn

pub unsafe fn deref_inner(&self) -> RefInner<'_, I>

Safety

This is a thread unsafe way to get When using, please make sure there is no thread safety problem

Trait Implementations

impl<I> Default for Actor<I>

where I: Default,

fn default() -> Actor<I>

Returns the “default value” for a type.

impl<T: SessionSave + 'static> INetXClient for Actor<NetXClient<T>>

Implementation of the INetXClient trait for Actor<NetXClient<T>>.

This implementation provides the external operations for the NetXClient, including methods for initializing the controller, connecting to the network, getting configuration and session information, generating serial IDs, and checking connection status.

async fn init<C: IController + Sync + Send + 'static>(&self, controller: C)

Initializes the NetX client controller.

async fn connect_network(self: &Arc<Self>) -> Result<()>

Connects to the network.

fn get_tls_config(&self) -> TlsConfig

Gets the TLS configuration.

fn get_address(&self) -> String

Gets the NetX server address.

fn get_service_info(&self) -> ServerOption

Gets the NetX client service configuration.

fn get_session_id(&self) -> i64

Gets the NetX session ID.

fn get_mode(&self) -> u8

Gets the NetX mode.

fn new_serial(&self) -> i64

Generates a new serial ID.

fn is_connect(&self) -> bool

Checks if the client is connected to the server.

async fn get_peer(&self) -> Option<Arc<NetPeer>>

Gets the TCP socket peer.

async fn set_network_client(&self, client: Arc<NetPeer>)

Sets the TCP socket peer.

async fn get_callback_len(&self) -> usize

Gets the length of the request wait callback.

async fn close(&self) -> Result<()>

Closes the NetX client.

async fn call(&self, serial: i64, buff: Data) -> Result<RetResult>

Calls a function with the given serial and buffer.

async fn run(&self, buff: Data) -> Result<()>

Runs the client with the given buffer.

impl<T> SocketClientTrait for Actor<TcpClient<T>>

where T: AsyncRead + AsyncWrite + Send + 'static,

async fn send<B>(&self, buff: B) -> Result<usize, Error>

where B: Deref<Target = [u8]> + Send + Sync + 'static,

async fn send_all<B>(&self, buff: B) -> Result<(), Error>

where B: Deref<Target = [u8]> + Send + Sync + 'static,

async fn send_ref(&self, buff: &[u8]) -> Result<usize, Error>

async fn send_all_ref(&self, buff: &[u8]) -> Result<(), Error>

async fn flush(&self) -> Result<(), Error>

async fn disconnect(&self) -> Result<(), Error>